Skip to content

Instantly share code, notes, and snippets.

@cdbartholomew

cdbartholomew/gist:27cf67f28efbdaac89d34f425a162e70

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/27cf67f28efbdaac89d34f425a162e70 to your computer and use it in GitHub Desktop.
Save cdbartholomew/27cf67f28efbdaac89d34f425a162e70 to your computer and use it in GitHub Desktop.
Download ZIP
Shared consumer 1
Raw
gistfile1.txt
2019-11-09 13:48:37.658 INFO ConsumerImpl:170 | [persistent://azure-kafkaesque-io/local-uscentral1-azure/subscription-demo, shared, 0] Created consumer on broker [172.16.0.117:46688 -> 52.242.224.253:6651]
2019-11-09 13:58:37.361 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! 0'' id='(71,0,-1,-1)'
Received message 'b'Hello World! 2'' id='(71,2,-1,-1)'
Received message 'b'Hello World! 4'' id='(71,4,-1,-1)'
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment