Build failed in Jenkins: pulsar-master #772

[Apache Jenkins Server]

See 
<https://builds.apache.org/job/pulsar-master/772/display/redirect?page=changes>

Changes:

[github] Ensure standalone service comes back quickly after ungraceful restarts

[guosijie] Don't initialize /managed-ledgers on client creation (#2379) (#2509)

[guosijie] Issue 2313: create a JDBC sink connector (#2440)

------------------------------------------
[...truncated 2.77 MB...]
2018-09-06 04:05:16.380 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 04:05:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 04:05:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 04:05:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 04:05:17.106 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 04:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:05:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:05:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:05:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:05:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:05:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:14:58.141 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 04:14:58.294 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 04:14:59.375 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 04:15:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 04:15:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 04:15:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 04:15:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 04:15:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 04:15:16.380 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 04:15:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 04:15:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 04:15:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 04:15:17.106 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:15:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:15:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 04:15:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:15:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:15:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:15:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:15:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:15:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:24:58.141 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 04:24:58.294 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 04:24:59.375 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 04:25:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 04:25:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 04:25:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 04:25:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 04:25:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 04:25:16.380 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 04:25:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 04:25:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 04:25:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 04:25:17.106 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:25:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:25:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 04:25:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:25:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:25:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:25:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:25:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:25:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:34:58.141 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 04:34:58.294 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 04:34:59.375 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 04:35:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 04:35:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 04:35:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 04:35:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 04:35:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 04:35:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 04:35:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 04:35:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 04:35:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 04:35:17.106 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:35:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:35:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 04:35:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:35:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:35:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:35:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:35:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:35:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:44:58.141 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 04:44:58.294 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 04:44:59.375 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 04:45:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 04:45:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 04:45:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 04:45:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 04:45:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 04:45:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 04:45:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 04:45:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 04:45:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 04:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 04:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:45:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:45:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:45:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:45:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:45:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:54:58.141 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 04:54:58.294 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 04:54:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 04:55:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 04:55:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 04:55:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 04:55:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 04:55:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 04:55:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 04:55:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 04:55:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 04:55:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 04:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 04:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 04:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:55:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 04:55:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:55:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:55:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 04:55:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:04:58.142 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 05:04:58.295 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 05:04:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 05:05:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 05:05:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 05:05:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 05:05:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 05:05:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 05:05:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 05:05:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 05:05:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 05:05:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 05:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 05:05:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:05:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:05:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:05:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:05:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:05:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:14:58.142 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 05:14:58.295 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 05:14:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 05:15:16.181 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 05:15:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 05:15:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 05:15:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 05:15:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 05:15:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 05:15:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 05:15:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 05:15:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 05:15:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:15:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:15:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 05:15:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:15:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:15:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:15:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:15:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:15:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:24:58.142 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 05:24:58.295 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 05:24:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 05:25:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 05:25:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 05:25:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 05:25:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 05:25:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 05:25:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 05:25:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 05:25:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 05:25:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 05:25:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:25:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:25:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 05:25:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:25:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:25:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:25:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:25:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:25:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:34:58.142 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 05:34:58.295 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 05:34:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 05:35:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 05:35:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 05:35:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 05:35:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 05:35:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 05:35:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 05:35:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 05:35:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 05:35:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 05:35:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:35:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:35:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 05:35:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:35:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:35:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:35:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:35:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:35:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:44:58.142 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 05:44:58.295 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 05:44:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 05:45:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 05:45:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 05:45:16.298 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 05:45:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 05:45:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 05:45:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 05:45:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 05:45:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 05:45:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 05:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:45:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 05:45:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:45:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:45:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:45:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:45:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:45:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:54:58.142 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 5, totalBytesSent_ = 35, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 5], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 8.242ms, 90pct: 0.094ms, 99pct: 
0ms, 99.9pct: 0ms])
2018-09-06 05:54:58.295 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, totalNumBytesRecieved_ 
= 21, receivedMsgMap_ = {}, ackedMsgMap_ = {}, totalReceivedMsgMap_ = {[Key: 
Ok, Value: 3], [Key: TimeOut, Value: 2], }, totalAckedMsgMap_ = {[Key: {Result: 
Ok, ackType: 0}, Value: 3], })
2018-09-06 05:54:59.376 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1536104698.12,
 my-producer-name] , ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, 
sendMap_ = {}, latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 
0ms, 99.9pct: 0ms], totalMsgsSent_ = 2, totalBytesSent_ = 14, 
totalAcksReceived_ = , totalSendMap_ = {[Key: Ok, Value: 2], }, 
totalLatencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 
99.9pct: 0ms])
2018-09-06 05:55:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23137ms, 90pct: 9.90264ms, 99pct: 13.7568ms, 99.9pct: 25.1275ms])
2018-09-06 05:55:16.182 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 50, totalBytesSent_ = 495, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 50], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21316ms, 90pct: 9.5719ms, 99pct: 12.8513ms, 99.9pct: 23.8613ms])
2018-09-06 05:55:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 34, totalBytesSent_ = 336, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 34], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.26656ms, 90pct: 8.49708ms, 99pct: 8.6049ms, 99.9pct: 9.51933ms])
2018-09-06 05:55:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.18933ms, 90pct: 8.47038ms, 99pct: 8.96271ms, 99.9pct: 11.9522ms])
2018-09-06 05:55:16.299 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 33, totalBytesSent_ = 327, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 33], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.23304ms, 90pct: 8.6729ms, 99pct: 9.43522ms, 99.9pct: 13.9163ms])
2018-09-06 05:55:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.22155ms, 90pct: 8.44928ms, 99pct: 8.75363ms, 99.9pct: 10.9567ms])
2018-09-06 05:55:16.381 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 247, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.24097ms, 90pct: 8.39929ms, 99pct: 8.55252ms, 99.9pct: 9.38211ms])
2018-09-06 05:55:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.21088ms, 90pct: 8.46432ms, 99pct: 8.8441ms, 99.9pct: 10.4603ms])
2018-09-06 05:55:16.382 INFO  ProducerStatsImpl:91 | Producer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, ] 
, ProducerStatsImpl (numMsgsSent_ = 0, numBytesSent_ = 0, sendMap_ = {}, 
latencyAccumulator_ = Latencies [ 50pct: 0ms, 90pct: 0ms, 99pct: 0ms, 99.9pct: 
0ms], totalMsgsSent_ = 25, totalBytesSent_ = 248, totalAcksReceived_ = , 
totalSendMap_ = {[Key: Ok, Value: 25], }, totalLatencyAccumulator_ = Latencies 
[ 50pct: 8.31138ms, 90pct: 8.76753ms, 99pct: 9.63885ms, 99.9pct: 13.7189ms])
2018-09-06 05:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-0, 
my-pattern-consumer-sub, 0] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-1-partition-1, 
my-pattern-consumer-sub, 1] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 486, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 49], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 49], })
2018-09-06 05:55:17.107 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-0, 
my-pattern-consumer-sub, 2] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 336, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 34], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 34], })
2018-09-06 05:55:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-1, 
my-pattern-consumer-sub, 3] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:55:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-2-partition-2, 
my-pattern-consumer-sub, 4] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 327, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 33], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 33], })
2018-09-06 05:55:17.108 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-0, 
my-pattern-consumer-sub, 5] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:55:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-1, 
my-pattern-consumer-sub, 6] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 247, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:55:17.109 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-2, 
my-pattern-consumer-sub, 7] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
2018-09-06 05:55:17.110 INFO  ConsumerStatsImpl:64 | Consumer 
[persistent://sample/standalone/ns/my-python-pattern-consumer-3-partition-3, 
my-pattern-consumer-sub, 8] , ConsumerStatsImpl (numBytesRecieved_ = 0, 
totalNumBytesRecieved_ = 248, receivedMsgMap_ = {}, ackedMsgMap_ = {}, 
totalReceivedMsgMap_ = {[Key: Ok, Value: 25], }, totalAckedMsgMap_ = {[Key: 
{Result: Ok, ackType: 0}, Value: 25], })
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user nore...@github.com
Not sending mail to unregistered user guosi...@gmail.com
Not sending mail to unregistered user jiaz...@users.noreply.github.com
Not sending mail to unregistered user y.shiga.91+yush...@gmail.com