Skip to content

Instantly share code, notes, and snippets.

@cdbartholomew

cdbartholomew/gist:adf0b23231735260bb44eab042a7917a

Created November 9, 2019 19:44
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save cdbartholomew/adf0b23231735260bb44eab042a7917a to your computer and use it in GitHub Desktop.
Save cdbartholomew/adf0b23231735260bb44eab042a7917a to your computer and use it in GitHub Desktop.
Download ZIP
Exclusive consumer
Raw
gistfile1.txt
2019-11-09 13:58:14.122 INFO ConsumerStatsImpl:64 | Consumer [persistent://azure-kafkaesque-io/local-uscentral1-azure/subscription-demo, exclusive, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ = 0, receivedMsgMap_ = {[Key: TimeOut, Value: 200], }, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: TimeOut, Value: 200], }, totalAckedMsgMap_ = {})
Received message 'b'Hello World! 0'' id='(71,0,-1,-1)'
Received message 'b'Hello World! 1'' id='(71,1,-1,-1)'
Received message 'b'Hello World! 2'' id='(71,2,-1,-1)'
Received message 'b'Hello World! 3'' id='(71,3,-1,-1)'
Received message 'b'Hello World! 4'' id='(71,4,-1,-1)'
Received message 'b'Hello World! 5'' id='(71,5,-1,-1)'
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment