Skip to content

Instantly share code, notes, and snippets.

@cdbartholomew

cdbartholomew/gist:88a419a222b631fc2cd0a3759fb5b279

Created November 9, 2019 19:46
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/88a419a222b631fc2cd0a3759fb5b279 to your computer and use it in GitHub Desktop.
Save cdbartholomew/88a419a222b631fc2cd0a3759fb5b279 to your computer and use it in GitHub Desktop.
Download ZIP
Shared consumer 2
Raw
gistfile1.txt
2019-11-09 13:48:55.257 INFO ConsumerImpl:170 | [persistent://azure-kafkaesque-io/local-uscentral1-azure/subscription-demo, shared, 0] Created consumer on broker [172.16.0.117:47342 -> 52.242.224.253:6651]
2019-11-09 13:58:54.959 INFO ConsumerStatsImpl:64 | Consumer [persistent://azure-kafkaesque-io/local-uscentral1-azure/subscription-demo, shared, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ = 0, receivedMsgMap_ = {[Key: TimeOut, Value: 200], }, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: TimeOut, Value: 200], }, totalAckedMsgMap_ = {})
Received message 'b'Hello World! 1'' id='(71,1,-1,-1)'
Received message 'b'Hello World! 3'' id='(71,3,-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