-
Notifications
You must be signed in to change notification settings - Fork 0
/
demo-parallel.log
1621 lines (1616 loc) · 222 KB
/
demo-parallel.log
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
/home/joe/PycharmProjects/.venv/kafka-tr-issue-201011/bin/python /home/joe/PycharmProjects/kafka-tr-issue-201011/demo.py -b 172.31.31.3:9092 -t demoinput1602442758 -o demooutput1602442758
Running in PARALLEL mode
The input producer will produce all messages in parallel (at once) after the first message.
Processing took 1.8955812454223633
Send offset times: [0.0027625560760498047, 0.0019762516021728516, 0.10375642776489258, 0.10460805892944336, 0.10369443893432617, 0.10310721397399902, 0.1026458740234375, 0.10383033752441406, 0.1045694351196289, 0.10415911674499512, 0.10245347023010254, 0.10347795486450195, 0.10364031791687012, 0.10359859466552734, 0.10380077362060547, 0.10238766670227051, 0.10335779190063477, 0.10341238975524902, 0.10306930541992188, 0.10412240028381348]
Send offset times average: 0.09342151880264282
Relevant log snippet from the middle:
:DEMO:START 1602442988.8928254
%7|1602442988.892|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
%7|1602442988.892|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: send_offsets_to_transaction
%7|1602442988.892|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 50)
%7|1602442988.893|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 50, rtt 0.23ms)
%7|1602442988.893|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Retrying AddOffsetsToTxnRequest (v0, 78 bytes, retry 1/3, prev CorrId 50) in 100ms
%7|1602442988.893|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.893|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 51)
%7|1602442988.894|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 51, rtt 0.26ms)
%7|1602442988.894|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: AddPartitionsToTxn response: partition "demooutput1602442758": [0]: Broker: Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
%7|1602442988.914|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.914|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 52)
%7|1602442988.915|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 52, rtt 1.01ms)
%7|1602442988.915|ADDPARTS|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0] registered with transaction
%7|1602442988.915|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.915|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.915|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1602442988.915|PRODUCE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: Produce MessageSet with 1 message(s) (76 bytes, ApiVersion 7, MsgVersion 2, MsgId 11, BaseSeq 10, PID{Id:0,Epoch:3}, uncompressed)
%7|1602442988.915|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent ProduceRequest (v7, 168 bytes @ 0, CorrId 27)
%7|1602442988.916|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received ProduceResponse (v7, 70 bytes, CorrId 27, rtt 0.88ms)
%7|1602442988.916|MSGSET|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: MessageSet with 1 message(s) (MsgId 11, BaseSeq 10) delivered
%7|1602442988.993|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Moved 1 retry buffer(s) to output queue
%7|1602442988.993|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 53)
%7|1602442988.994|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 53, rtt 0.97ms)
%7|1602442988.994|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent TxnOffsetCommitRequest (v0, 128 bytes @ 0, CorrId 28)
%7|1602442988.995|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received TxnOffsetCommitResponse (v0, 46 bytes, CorrId 28, rtt 0.73ms)
:DEMO:END 1602442988.9952788 0.10245347023010254
Full output of the transactor:
%7|1602442986.034|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "kafka-tr-issue-201011-tr": updating member id "(not-set)" -> ""
%7|1602442986.034|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups
%7|1602442986.034|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Added new broker with NodeId -1
%7|1602442986.034|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: 172.31.31.3:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1602442986.034|BRKMAIN|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread
%7|1602442986.034|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1602442986.035|BROKER|rdkafka#consumer-1| [thrd:app]: 172.31.31.3:9092/bootstrap: Added new broker with NodeId -1
%7|1602442986.035|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.5.0 (0x10500ff) rdkafka#consumer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STATIC_LINKING GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS STATIC_LIB_zlib ZLIB STATIC_LIB_libcrypto STATIC_LIB_libssl SSL STATIC_LIB_libzstd ZSTD HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff)
%7|1602442986.035|BRKMAIN|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enter main broker thread
%7|1602442986.035|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op ASSIGN (v0) in state init (join state init, v1 vs 0)
%7|1602442986.035|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": new assignment of 1 partition(s) in join state init
%7|1602442986.035|TOPIC|rdkafka#consumer-1| [thrd:main]: New local topic: demoinput1602442758
%7|1602442986.035|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW demoinput1602442758 [-1] 0x7f4ea4003050 (at rd_kafka_topic_new0:441)
%7|1602442986.035|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW demoinput1602442758 [0] 0x7f4ea40035b0 (at rd_kafka_toppar_desired_add:618)
%7|1602442986.035|DESIRED|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0]: marking as DESIRED
%7|1602442986.035|DESIRED|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0]: adding to DESIRED list
%7|1602442986.035|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": rd_kafka_cgrp_assign:2600: new version barrier v2
%7|1602442986.035|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": assigning 1 partition(s) in join state init
%7|1602442986.035|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changed join state init -> assigned (v2, state init)
%7|1602442986.035|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": rd_kafka_cgrp_partitions_fetch_start0:1878: new version barrier v3
%7|1602442986.035|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=no, v3, line 2651)
%7|1602442986.035|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1602442986.035|FETCHSTART|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0] offset INVALID
%7|1602442986.035|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1602442986.035|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0] offset INVALID
%7|1602442986.035|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset fetch error: Local: Waiting for coordinator
%7|1602442986.035|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changed state init -> query-coord (v3, join-state assigned)
%7|1602442986.035|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1602442986.035|CONNECT|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
%7|1602442986.035|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": no broker available for coordinator query: intervaled in state query-coord
%7|1602442986.035|CONNECT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Received CONNECT op
%7|1602442986.035|STATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1602442986.035|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.035|CONNECT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1602442986.035|STATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1602442986.035|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.035|WAKEUPFD|rdkafka#producer-2| [thrd:main]: TxnCoordinator: Enabled low-latency ops queue wake-ups
%7|1602442986.035|BRKMAIN|rdkafka#producer-2| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1602442986.035|CONNECT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Connecting to ipv4#172.31.31.3:9092 (plaintext) with socket 11
%7|1602442986.035|BROKER|rdkafka#producer-2| [thrd:main]: TxnCoordinator: Added new broker with NodeId -1
%7|1602442986.035|WAKEUPFD|rdkafka#producer-2| [thrd:app]: 172.31.31.3:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1602442986.035|BRKMAIN|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Enter main broker thread
%7|1602442986.035|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1602442986.035|BROKER|rdkafka#producer-2| [thrd:app]: 172.31.31.3:9092/bootstrap: Added new broker with NodeId -1
%7|1602442986.035|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:app]: 172.31.31.3:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: broker in state TRY_CONNECT connecting
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: broker has no address yet: postponing connect
%7|1602442986.035|INIT|rdkafka#producer-2| [thrd:app]: librdkafka v1.5.0 (0x10500ff) rdkafka#producer-2 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STATIC_LINKING GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS STATIC_LIB_zlib ZLIB STATIC_LIB_libcrypto STATIC_LIB_libssl SSL STATIC_LIB_libzstd ZSTD HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff)
%7|1602442986.035|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: init_transactions
%7|1602442986.035|BRKMAIN|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enter main broker thread
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Received CONNECT op
%7|1602442986.035|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change Init -> WaitPID
%7|1602442986.035|STATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1602442986.035|IDEMPSTATE|rdkafka#producer-2| [thrd:main]: Idempotent producer state change Init -> RequestPID
%7|1602442986.035|TXN|rdkafka#producer-2| [thrd:main]: Starting PID FSM timer (fire immediately): Starting idempotent producer
%7|1602442986.035|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1602442986.035|STATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1602442986.035|CONNECT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Connected to ipv4#172.31.31.3:9092
%7|1602442986.035|CONNECTED|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Connected (#1)
%7|1602442986.035|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.035|FEATURE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1602442986.035|STATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1602442986.035|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.035|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Sent ApiVersionRequest (v3, 66 bytes @ 0, CorrId 1)
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Connecting to ipv4#172.31.31.3:9092 (plaintext) with socket 16
%7|1602442986.035|CONNECT|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Connected to ipv4#172.31.31.3:9092
%7|1602442986.035|CONNECTED|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Connected (#1)
%7|1602442986.035|FEATURE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1602442986.035|STATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1602442986.035|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.035|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Sent ApiVersionRequest (v3, 66 bytes @ 0, CorrId 1)
%7|1602442986.036|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.88ms)
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker API support:
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Produce (0) Versions 0..8
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Fetch (1) Versions 0..11
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Offset (2) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Metadata (3) Versions 0..9
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey StopReplica (5) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..6
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..8
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..7
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..7
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ListGroups (16) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-45? (45) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-46? (46) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-47? (47) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature MsgVer1
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature MsgVer2
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1602442986.036|CONNECT|rdkafka#producer-2| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: acquire ProducerID
%7|1602442986.036|PIDBROKER|rdkafka#producer-2| [thrd:main]: No brokers available for Transactions (2 broker(s) known)
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature ApiVersion
%7|1602442986.036|TXNCOORD|rdkafka#producer-2| [thrd:main]: Unable to query for transaction coordinator: No brokers available for Transactions (2 broker(s) known)
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature ThrottleTime
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature Sasl
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature SaslHandshake
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature LZ4
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature OffsetTime
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature IdempotentProducer
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature ZSTD
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature SaslAuthReq
%7|1602442986.036|FEATURE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1602442986.036|STATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1602442986.036|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.036|METADATA|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Hinted cache of 1/1 topic(s) being queried
%7|1602442986.036|METADATA|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Requesting metadata for 1/1 topics: connected
%7|1602442986.036|METADATA|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Request metadata for 1 topic(s): connected
%7|1602442986.036|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.90ms)
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker API support:
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Produce (0) Versions 0..8
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Fetch (1) Versions 0..11
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Offset (2) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Metadata (3) Versions 0..9
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey StopReplica (5) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..6
%7|1602442986.036|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Sent MetadataRequest (v4, 54 bytes @ 0, CorrId 2)
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..8
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..7
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..7
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ListGroups (16) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..5
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..4
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-45? (45) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-46? (46) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: ApiKey Unknown-47? (47) Versions 0..0
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature MsgVer1
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature MsgVer2
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature ApiVersion
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature ThrottleTime
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature Sasl
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature SaslHandshake
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature LZ4
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature OffsetTime
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature IdempotentProducer
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature ZSTD
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1602442986.036|APIVERSION|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Enabling feature SaslAuthReq
%7|1602442986.036|FEATURE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1602442986.036|STATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1602442986.036|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.036|METADATA|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Request metadata for brokers only: connected
%7|1602442986.036|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1602442986.036|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Received MetadataResponse (v4, 63 bytes, CorrId 2, rtt 0.27ms)
%7|1602442986.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/bootstrap: ===== Received metadata: connected =====
%7|1602442986.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/bootstrap: ClusterId: P3Dm2isBTn-IXhcu_D5JSw, ControllerId: 1001
%7|1602442986.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/bootstrap: 1 brokers, 0 topics
%7|1602442986.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/bootstrap: Broker #0/1: 172.31.31.3:9092 NodeId 1001
%7|1602442986.036|CLUSTERID|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/bootstrap: ClusterId update "" -> "P3Dm2isBTn-IXhcu_D5JSw"
%7|1602442986.036|CONTROLLERID|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/bootstrap: ControllerId update -1 -> 1001
%7|1602442986.036|BROADCAST|rdkafka#producer-2| [thrd:main]: Broadcasting state change
%7|1602442986.036|UPDATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: NodeId changed from -1 to 1001
%7|1602442986.036|UPDATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Name changed from 172.31.31.3:9092/bootstrap to 172.31.31.3:9092/1001
%7|1602442986.036|LEADER|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Mapped 0 partition(s) to broker
%7|1602442986.036|STATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Broker changed state UP -> UPDATE
%7|1602442986.036|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.036|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.036|STATE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Broker changed state UPDATE -> UP
%7|1602442986.036|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.036|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FindCoordinatorRequest (v2, 43 bytes @ 0, CorrId 3)
%7|1602442986.037|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: Received MetadataResponse (v4, 124 bytes, CorrId 2, rtt 0.58ms)
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: ===== Received metadata (for 1 requested topics): connected =====
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: ClusterId: P3Dm2isBTn-IXhcu_D5JSw, ControllerId: 1001
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: 1 brokers, 1 topics
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: Broker #0/1: 172.31.31.3:9092 NodeId 1001
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: Topic #0/1: demoinput1602442758 with 1 partitions
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:main]: Topic demoinput1602442758 changed state unknown -> exists
%7|1602442986.037|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic demoinput1602442758 partition count changed from 0 to 1
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: Topic demoinput1602442758 partition 0 Leader 1001
%7|1602442986.037|BRKDELGT|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0]: delegate to broker (none) (rktp 0x7f4ea40035b0, term 0, ref 3)
%7|1602442986.037|BRKDELGT|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0]: delegating to broker :0/internal for partition with 0 messages (0 bytes) queued
%7|1602442986.037|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic demoinput1602442758 [0] 0x7f4ea40035b0 from (none) to :0/internal (sending PARTITION_JOIN to :0/internal)
%7|1602442986.037|METADATA|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1602442986.037|CLUSTERID|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: ClusterId update "" -> "P3Dm2isBTn-IXhcu_D5JSw"
%7|1602442986.037|CONTROLLERID|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: ControllerId update -1 -> 1001
%7|1602442986.037|TOPBRK|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Topic demoinput1602442758 [0]: joining broker (rktp 0x7f4ea40035b0, 0 message(s) queued)
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd::0/internal]: Broadcasting state change
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1602442986.037|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/bootstrap: Group "kafka-tr-issue-201011-tr": querying for coordinator: intervaled in state query-coord
%7|1602442986.037|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changed state query-coord -> wait-coord (v3, join-state assigned)
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1602442986.037|UPDATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/bootstrap: NodeId changed from -1 to 1001
%7|1602442986.037|UPDATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Name changed from 172.31.31.3:9092/bootstrap to 172.31.31.3:9092/1001
%7|1602442986.037|TOPICUPD|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Topic demoinput1602442758 [0]: migrating from broker -1 to 1001 (leader is 1001): broker node information updated
%7|1602442986.037|BRKDELGT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: demoinput1602442758 [0]: delegate to broker 172.31.31.3:9092/1001 (rktp 0x7f4ea40035b0, term 0, ref 3)
%7|1602442986.037|BRKDELGT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: demoinput1602442758 [0]: no longer delegated to broker :0/internal
%7|1602442986.037|BRKDELGT|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: demoinput1602442758 [0]: delegating to broker 172.31.31.3:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1602442986.037|BRKMIGR|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Migrating topic demoinput1602442758 [0] 0x7f4ea40035b0 from :0/internal to 172.31.31.3:9092/1001 (sending PARTITION_LEAVE to :0/internal)
%7|1602442986.037|LEADER|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Mapped 1 partition(s) to broker
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Broker changed state UP -> UPDATE
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.037|TOPBRK|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Topic demoinput1602442758 [0]: leaving broker (0 messages in xmitq, next broker 172.31.31.3:9092/1001, rktp 0x7f4ea40035b0)
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd::0/internal]: Broadcasting state change
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.037|TOPBRK|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0]: joining broker (rktp 0x7f4ea40035b0, 0 message(s) queued)
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Broker changed state UPDATE -> UP
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442986.037|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FindCoordinatorResponse (v2, 33 bytes, CorrId 3, rtt 0.33ms)
%7|1602442986.037|TXNCOORD|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: FindCoordinator response: Transaction coordinator is broker 1001 (172.31.31.3:9092)
%7|1602442986.037|TXNCOORD|rdkafka#producer-2| [thrd:main]: Transaction coordinator changed from (none) -> 172.31.31.3:9092/1001: FindCoordinator response
%7|1602442986.037|NODENAME|rdkafka#producer-2| [thrd:main]: TxnCoordinator: Broker nodename changed from "" to "172.31.31.3:9092"
%7|1602442986.037|IDEMPSTATE|rdkafka#producer-2| [thrd:main]: Idempotent producer state change RequestPID -> WaitTransport
%7|1602442986.037|TXN|rdkafka#producer-2| [thrd:main]: Starting PID FSM timer: No broker available
%7|1602442986.037|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FindCoordinatorRequest (v2, 48 bytes @ 0, CorrId 3)
%7|1602442986.037|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FindCoordinatorResponse (v2, 33 bytes, CorrId 3, rtt 0.14ms)
%7|1602442986.037|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/1001: Group "kafka-tr-issue-201011-tr" coordinator is 172.31.31.3:9092 id 1001
%7|1602442986.037|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changing coordinator -1 -> 1001
%7|1602442986.037|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" coordinator set to broker 172.31.31.3:9092/1001
%7|1602442986.037|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changed state wait-coord -> wait-broker-transport (v3, join-state assigned)
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1602442986.037|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "172.31.31.3:9092"
%7|1602442986.037|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/1001: Group "kafka-tr-issue-201011-tr": querying for coordinator: intervaled in state wait-broker-transport
%7|1602442986.037|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received CONNECT op
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.037|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Closing connection due to nodename change (after 0ms in state TRY_CONNECT) (_TRANSPORT)
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> DOWN
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.037|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Purging bufq with 0 buffers
%7|1602442986.037|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Purging bufq with 0 buffers
%7|1602442986.037|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updating 0 buffers on connection reset
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT
%7|1602442986.037|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FindCoordinatorRequest (v2, 48 bytes @ 0, CorrId 4)
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.037|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: broker in state TRY_CONNECT connecting
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.037|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connecting to ipv4#172.31.31.3:9092 (plaintext) with socket 17
%7|1602442986.037|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connected to ipv4#172.31.31.3:9092
%7|1602442986.037|CONNECTED|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Connected (#1)
%7|1602442986.037|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1602442986.037|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1602442986.037|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.037|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent ApiVersionRequest (v3, 66 bytes @ 0, CorrId 1)
%7|1602442986.037|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FindCoordinatorResponse (v2, 33 bytes, CorrId 4, rtt 0.29ms)
%7|1602442986.037|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/1001: Group "kafka-tr-issue-201011-tr" coordinator is 172.31.31.3:9092 id 1001
%7|1602442986.038|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.34ms)
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Broker API support:
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Produce (0) Versions 0..8
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Fetch (1) Versions 0..11
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Offset (2) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Metadata (3) Versions 0..9
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey StopReplica (5) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey UpdateMetadata (6) Versions 0..6
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey ControlledShutdown (7) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey OffsetCommit (8) Versions 0..8
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey OffsetFetch (9) Versions 0..7
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey FindCoordinator (10) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey JoinGroup (11) Versions 0..7
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Heartbeat (12) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey LeaveGroup (13) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey SyncGroup (14) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DescribeGroups (15) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey ListGroups (16) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey SaslHandshake (17) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey ApiVersion (18) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey CreateTopics (19) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DeleteTopics (20) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DeleteRecords (21) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey InitProducerId (22) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey EndTxn (26) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DescribeAcls (29) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey CreateAcls (30) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DeleteAcls (31) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DescribeConfigs (32) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey AlterConfigs (33) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DescribeLogDirs (35) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey CreatePartitions (37) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey DeleteGroups (42) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Unknown-43? (43) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Unknown-44? (44) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Unknown-45? (45) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Unknown-46? (46) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: ApiKey Unknown-47? (47) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature MsgVer1: Produce (2..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature MsgVer1
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature MsgVer2: Produce (3..3) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature MsgVer2
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ApiVersion
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature BrokerGroupCoordinator
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature BrokerBalancedConsumer
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ThrottleTime
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature Sasl
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature SaslHandshake
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature LZ4
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature OffsetTime: Offset (1..1) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature OffsetTime
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature IdempotentProducer
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature ZSTD: Produce (7..7) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature ZSTD: Fetch (10..10) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature ZSTD
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Enabling feature SaslAuthReq
%7|1602442986.038|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1602442986.038|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP
%7|1602442986.038|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1602442986.038|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1602442986.038|FAIL|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Closing connection due to nodename change (after 3ms in state TRY_CONNECT) (_TRANSPORT)
%7|1602442986.038|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state TRY_CONNECT -> DOWN
%7|1602442986.038|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.038|BUFQ|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Purging bufq with 0 buffers
%7|1602442986.038|BUFQ|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Purging bufq with 0 buffers
%7|1602442986.038|BUFQ|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Updating 0 buffers on connection reset
%7|1602442986.038|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state DOWN -> INIT
%7|1602442986.038|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.038|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1602442986.038|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.038|CONNECT|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: broker in state TRY_CONNECT connecting
%7|1602442986.038|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state TRY_CONNECT -> CONNECT
%7|1602442986.038|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.038|CONNECT|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Connecting to ipv4#172.31.31.3:9092 (plaintext) with socket 18
%7|1602442986.038|CONNECT|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Connected to ipv4#172.31.31.3:9092
%7|1602442986.038|CONNECTED|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Connected (#1)
%7|1602442986.038|FEATURE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1602442986.038|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1602442986.038|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.038|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent ApiVersionRequest (v3, 66 bytes @ 0, CorrId 1)
%7|1602442986.038|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received ApiVersionResponse (v3, 344 bytes, CorrId 1, rtt 0.27ms)
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Broker API support:
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Produce (0) Versions 0..8
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Fetch (1) Versions 0..11
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Offset (2) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Metadata (3) Versions 0..9
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey StopReplica (5) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey UpdateMetadata (6) Versions 0..6
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey ControlledShutdown (7) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey OffsetCommit (8) Versions 0..8
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey OffsetFetch (9) Versions 0..7
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey FindCoordinator (10) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey JoinGroup (11) Versions 0..7
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Heartbeat (12) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey LeaveGroup (13) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey SyncGroup (14) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DescribeGroups (15) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey ListGroups (16) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey SaslHandshake (17) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey ApiVersion (18) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey CreateTopics (19) Versions 0..5
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DeleteTopics (20) Versions 0..4
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DeleteRecords (21) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey InitProducerId (22) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey EndTxn (26) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DescribeAcls (29) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey CreateAcls (30) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DeleteAcls (31) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DescribeConfigs (32) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey AlterConfigs (33) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DescribeLogDirs (35) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey CreatePartitions (37) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey DeleteGroups (42) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Unknown-43? (43) Versions 0..2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Unknown-44? (44) Versions 0..1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Unknown-45? (45) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Unknown-46? (46) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: ApiKey Unknown-47? (47) Versions 0..0
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature MsgVer1: Produce (2..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature MsgVer1
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature MsgVer2: Produce (3..3) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature MsgVer2
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature ApiVersion
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature BrokerGroupCoordinator
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature BrokerBalancedConsumer
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature ThrottleTime
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature Sasl
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature SaslHandshake
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature LZ4
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature OffsetTime: Offset (1..1) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature OffsetTime
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature IdempotentProducer
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature ZSTD: Produce (7..7) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature ZSTD: Fetch (10..10) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature ZSTD
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1602442986.038|APIVERSION|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Enabling feature SaslAuthReq
%7|1602442986.038|FEATURE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1602442986.038|STATE|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator: Broker changed state APIVERSION_QUERY -> UP
%7|1602442986.038|BROADCAST|rdkafka#producer-2| [thrd:TxnCoordinator]: Broadcasting state change
%7|1602442986.038|METADATA|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Request metadata for brokers only: connected
%7|1602442986.038|COORD|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Transaction coordinator is now up
%7|1602442986.038|GETPID|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Acquiring ProducerId
%7|1602442986.039|IDEMPSTATE|rdkafka#producer-2| [thrd:main]: Idempotent producer state change WaitTransport -> WaitPID
%7|1602442986.039|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1602442986.039|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent InitProducerIdRequest (v1, 46 bytes @ 0, CorrId 3)
%7|1602442986.039|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received MetadataResponse (v4, 63 bytes, CorrId 2, rtt 0.15ms)
%7|1602442986.039|METADATA|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: ===== Received metadata: connected =====
%7|1602442986.039|METADATA|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: ClusterId: P3Dm2isBTn-IXhcu_D5JSw, ControllerId: 1001
%7|1602442986.039|METADATA|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: 1 brokers, 0 topics
%7|1602442986.039|METADATA|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Broker #0/1: 172.31.31.3:9092 NodeId 1001
%7|1602442986.039|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received InitProducerIdResponse (v1, 16 bytes, CorrId 3, rtt 0.81ms)
%7|1602442986.039|GETPID|rdkafka#producer-2| [thrd:main]: Acquired PID{Id:0,Epoch:3}
%7|1602442986.039|IDEMPSTATE|rdkafka#producer-2| [thrd:main]: Idempotent producer state change WaitPID -> Assigned
%7|1602442986.039|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change WaitPID -> ReadyNotAcked
%7|1602442986.039|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442986.039|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442986.039|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: init_transactions
%7|1602442986.039|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change ReadyNotAcked -> Ready
%7|1602442986.039|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change Ready -> InTransaction
%7|1602442986.039|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442986.039|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
=== Starting Consume-Transform-Process loop ===
%7|1602442986.536|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FindCoordinatorRequest (v2, 43 bytes @ 0, CorrId 4)
%7|1602442986.537|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FindCoordinatorResponse (v2, 33 bytes, CorrId 4, rtt 0.56ms)
%7|1602442986.537|TXNCOORD|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: FindCoordinator response: Transaction coordinator is broker 1001 (172.31.31.3:9092)
%7|1602442987.034|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changed state wait-broker-transport -> up (v3, join-state assigned)
%7|1602442987.034|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1602442987.034|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": rd_kafka_cgrp_partitions_fetch_start0:1878: new version barrier v4
%7|1602442987.034|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=no, v4, line 3431)
%7|1602442987.034|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1602442987.034|FETCHSTART|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0] offset INVALID
%7|1602442987.034|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: OffsetFetchRequest(v1) for 1/1 partition(s)
%7|1602442987.034|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: Fetch committed offsets for 1/1 partition(s)
%7|1602442987.035|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Sent OffsetFetchRequest (v1, 87 bytes @ 0, CorrId 2)
%7|1602442987.035|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1001: Received OffsetFetchResponse (v1, 52 bytes, CorrId 2, rtt 0.58ms)
%7|1602442987.035|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1602442987.035|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0] offset INVALID
%7|1602442987.035|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic demoinput1602442758 [0]: setting default offset INVALID
%7|1602442987.035|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: OffsetFetchResponse: demoinput1602442758 [0] offset 60, metadata 0 byte(s)
%7|1602442987.035|OFFFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1001: OffsetFetch for 1/1 partition(s) returned Success
%7|1602442987.035|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": rd_kafka_cgrp_partitions_fetch_start0:1878: new version barrier v5
%7|1602442987.035|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=yes, v5, line 1810)
%7|1602442987.035|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1602442987.035|FETCHSTART|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0] offset 60
%7|1602442987.035|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" changed join state assigned -> started (v5, state up)
%7|1602442987.035|BARRIER|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0]: rd_kafka_toppar_op_fetch_start:2299: new version barrier v2
%7|1602442987.035|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming demoinput1602442758 [0] at offset 60 (v2)
%7|1602442987.035|OP|rdkafka#consumer-1| [thrd:main]: demoinput1602442758 [0] received op FETCH_START (v2) in fetch-state none (opv1)
%7|1602442987.035|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for demoinput1602442758 [0] in state none at offset 60 (v2)
%7|1602442987.035|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition demoinput1602442758 [0] changed fetch state none -> active
%7|1602442987.035|FETCH|rdkafka#consumer-1| [thrd:main]: Partition demoinput1602442758 [0] start fetching at offset 60
%7|1602442987.035|WAKEUP|rdkafka#consumer-1| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442987.035|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op PARTITION_JOIN in state up (join state started, v5) for demoinput1602442758 [0]
%7|1602442987.035|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr": add demoinput1602442758 [0]
%7|1602442987.035|FETCHDEC|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: Topic demoinput1602442758 [0]: fetch decide: updating to version 2 (was 0) at offset 60 (was 0)
%7|1602442987.035|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] in state active at offset 60 (0/100000 msgs, 0/65536 kb queued, opv 2) is fetchable
%7|1602442987.035|FETCHADD|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Added demoinput1602442758 [0] to fetch list (1 entries, opv 2, 0 messages queued): fetchable
%7|1602442987.035|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 60 (v2)
%7|1602442987.035|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442987.035|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 5)
%7|1602442987.537|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 88 bytes, CorrId 5, rtt 501.40ms)
%7|1602442987.537|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 0, error "Success", MaxOffset 60, LSO 60, Ver 2/2
%7|1602442987.537|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 60 (v2)
%7|1602442987.537|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442987.537|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 6)
=== Reached the end of demoinput1602442758 [0] at 60====
%7|1602442987.537|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
=== Reached end of input ===
%7|1602442988.007|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 6, rtt 470.12ms)
%7|1602442988.007|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 61, LSO 61, Ver 2/2
%7|1602442988.007|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 60, 0 ctrl msgs, uncompressed)
%7|1602442988.007|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 61 (v2)
%7|1602442988.007|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.007|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 7)
%7|1602442988.007|TOPIC|rdkafka#producer-2| [thrd:app]: New local topic: demooutput1602442758
%7|1602442988.007|TOPPARNEW|rdkafka#producer-2| [thrd:app]: NEW demooutput1602442758 [-1] 0x558f46383510 (at rd_kafka_topic_new0:441)
=== Committing transaction with 1 messages at input offset 60 ===
:DEMO:START 1602442988.0078986
%7|1602442988.007|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
%7|1602442988.007|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: send_offsets_to_transaction
%7|1602442988.008|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 4)
%7|1602442988.009|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 4, rtt 1.19ms)
%7|1602442988.009|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FindCoordinatorRequest (v2, 48 bytes @ 0, CorrId 5)
%7|1602442988.009|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FindCoordinatorResponse (v2, 33 bytes, CorrId 5, rtt 0.38ms)
%7|1602442988.009|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent TxnOffsetCommitRequest (v0, 128 bytes @ 0, CorrId 6)
%7|1602442988.010|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received TxnOffsetCommitResponse (v0, 46 bytes, CorrId 6, rtt 0.88ms)
:DEMO:END 1602442988.0106611 0.0027625560760498047
%7|1602442988.010|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction (begin)
%7|1602442988.010|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change InTransaction -> BeginCommit
%7|1602442988.010|TXNCOMMIT|rdkafka#producer-2| [thrd:app]: Flushing 1 outstanding message(s) prior to commit
%7|1602442988.035|NOINFO|rdkafka#producer-2| [thrd:main]: Topic demooutput1602442758 metadata information unknown
%7|1602442988.035|NOINFO|rdkafka#producer-2| [thrd:main]: Topic demooutput1602442758 partition count is zero: should refresh metadata
%7|1602442988.035|METADATA|rdkafka#producer-2| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1602442988.035|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Request metadata for 1 topic(s): refresh unavailable topics
%7|1602442988.035|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent MetadataRequest (v4, 54 bytes @ 0, CorrId 7)
%7|1602442988.036|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received MetadataResponse (v4, 124 bytes, CorrId 7, rtt 0.72ms)
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: ClusterId: P3Dm2isBTn-IXhcu_D5JSw, ControllerId: 1001
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: 1 brokers, 1 topics
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Broker #0/1: 172.31.31.3:9092 NodeId 1001
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Topic #0/1: demooutput1602442758 with 1 partitions
%7|1602442988.036|STATE|rdkafka#producer-2| [thrd:main]: Topic demooutput1602442758 changed state unknown -> exists
%7|1602442988.036|PARTCNT|rdkafka#producer-2| [thrd:main]: Topic demooutput1602442758 partition count changed from 0 to 1
%7|1602442988.036|TOPPARNEW|rdkafka#producer-2| [thrd:main]: NEW demooutput1602442758 [0] 0x7f4e940050e0 (at rd_kafka_topic_partition_cnt_update:750)
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: Topic demooutput1602442758 partition 0 Leader 1001
%7|1602442988.036|BRKDELGT|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0]: delegate to broker 172.31.31.3:9092/1001 (rktp 0x7f4e940050e0, term 0, ref 2)
%7|1602442988.036|BRKDELGT|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0]: delegating to broker 172.31.31.3:9092/1001 for partition with 0 messages (0 bytes) queued
%7|1602442988.036|BRKMIGR|rdkafka#producer-2| [thrd:main]: Migrating topic demooutput1602442758 [0] 0x7f4e940050e0 from (none) to 172.31.31.3:9092/1001 (sending PARTITION_JOIN to 172.31.31.3:9092/1001)
%7|1602442988.036|PARTCNT|rdkafka#producer-2| [thrd:main]: Partitioning 1 unassigned messages in topic demooutput1602442758 to 1 partitions
%7|1602442988.036|TOPBRK|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demooutput1602442758 [0]: joining broker (rktp 0x7f4e940050e0, 0 message(s) queued)
%7|1602442988.036|FETCHADD|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Added demooutput1602442758 [0] to active list (1 entries, opv 0, 0 messages queued): joining
%7|1602442988.036|DRAIN|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: demooutput1602442758 [0] beginning partition drain: wait for outstanding requests to finish before producing to new leader
%7|1602442988.036|BROADCAST|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: Broadcasting state change
%7|1602442988.036|UAS|rdkafka#producer-2| [thrd:main]: 1/1 messages were partitioned in topic demooutput1602442758
%7|1602442988.036|METADATA|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: 1/1 requested topic(s) seen in metadata
%7|1602442988.036|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] all in-flight requests drained from queue
%7|1602442988.037|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.037|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 5)
%7|1602442988.038|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 5, rtt 0.92ms)
%7|1602442988.038|ADDPARTS|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0] registered with transaction
%7|1602442988.038|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.038|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.038|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1602442988.038|NEWPID|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: demooutput1602442758 [0] changed PID{Invalid} -> PID{Id:0,Epoch:3} with base MsgId 1
%7|1602442988.038|RESETSEQ|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: demooutput1602442758 [0] resetting epoch base seq from 0 to 1
%7|1602442988.038|PRODUCE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: Produce MessageSet with 1 message(s) (76 bytes, ApiVersion 7, MsgVersion 2, MsgId 1, BaseSeq 0, PID{Id:0,Epoch:3}, uncompressed)
%7|1602442988.038|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent ProduceRequest (v7, 168 bytes @ 0, CorrId 8)
%7|1602442988.038|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received ProduceResponse (v7, 70 bytes, CorrId 8, rtt 0.63ms)
%7|1602442988.038|MSGSET|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: MessageSet with 1 message(s) (MsgId 1, BaseSeq 0) delivered
%7|1602442988.038|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction
%7|1602442988.038|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change BeginCommit -> CommittingTransaction
%7|1602442988.039|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent EndTxnRequest (v1, 53 bytes @ 0, CorrId 6)
%7|1602442988.039|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received EndTxnResponse (v1, 6 bytes, CorrId 6, rtt 0.88ms)
%7|1602442988.039|TXNCOMPLETE|rdkafka#producer-2| [thrd:main]: Transaction successfully committed
%7|1602442988.039|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change CommittingTransaction -> Ready
%7|1602442988.039|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change Ready -> InTransaction
%7|1602442988.039|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.039|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.047|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 7, rtt 40.01ms)
%7|1602442988.047|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 62, LSO 62, Ver 2/2
%7|1602442988.047|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 61, 0 ctrl msgs, uncompressed)
%7|1602442988.047|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 62 (v2)
%7|1602442988.047|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.047|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 8)
=== Committing transaction with 1 messages at input offset 61 ===
:DEMO:START 1602442988.0477252
%7|1602442988.047|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
%7|1602442988.047|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: send_offsets_to_transaction
%7|1602442988.048|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 7)
%7|1602442988.048|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.048|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 8)
%7|1602442988.048|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 7, rtt 0.80ms)
%7|1602442988.048|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent TxnOffsetCommitRequest (v0, 128 bytes @ 0, CorrId 9)
%7|1602442988.049|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 8, rtt 0.87ms)
%7|1602442988.049|ADDPARTS|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0] registered with transaction
%7|1602442988.049|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.049|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.049|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received TxnOffsetCommitResponse (v0, 46 bytes, CorrId 9, rtt 0.76ms)
%7|1602442988.049|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (1 added from partition queue)
:DEMO:END 1602442988.0497015 0.0019762516021728516
%7|1602442988.049|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction (begin)
%7|1602442988.049|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change InTransaction -> BeginCommit
%7|1602442988.049|TXNCOMMIT|rdkafka#producer-2| [thrd:app]: Flushing 1 outstanding message(s) prior to commit
%7|1602442988.053|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 8, rtt 5.82ms)
%7|1602442988.053|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 63, LSO 63, Ver 2/2
%7|1602442988.053|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 62, 0 ctrl msgs, uncompressed)
%7|1602442988.053|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 63 (v2)
%7|1602442988.053|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.053|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 9)
%7|1602442988.053|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (0 added from partition queue)
%7|1602442988.053|PRODUCE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: Produce MessageSet with 1 message(s) (76 bytes, ApiVersion 7, MsgVersion 2, MsgId 2, BaseSeq 1, PID{Id:0,Epoch:3}, uncompressed)
%7|1602442988.053|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent ProduceRequest (v7, 168 bytes @ 0, CorrId 10)
%7|1602442988.054|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received ProduceResponse (v7, 70 bytes, CorrId 10, rtt 0.84ms)
%7|1602442988.054|MSGSET|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: MessageSet with 1 message(s) (MsgId 2, BaseSeq 1) delivered
%7|1602442988.054|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction
%7|1602442988.054|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change BeginCommit -> CommittingTransaction
%7|1602442988.054|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent EndTxnRequest (v1, 53 bytes @ 0, CorrId 9)
%7|1602442988.055|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received EndTxnResponse (v1, 6 bytes, CorrId 9, rtt 0.69ms)
%7|1602442988.055|TXNCOMPLETE|rdkafka#producer-2| [thrd:main]: Transaction successfully committed
%7|1602442988.055|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change CommittingTransaction -> Ready
%7|1602442988.055|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change Ready -> InTransaction
%7|1602442988.055|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.055|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
=== Committing transaction with 1 messages at input offset 62 ===
:DEMO:START 1602442988.0555224
%7|1602442988.055|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
%7|1602442988.055|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: send_offsets_to_transaction
%7|1602442988.055|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 10)
%7|1602442988.056|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 10, rtt 0.80ms)
%7|1602442988.056|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Retrying AddOffsetsToTxnRequest (v0, 78 bytes, retry 1/3, prev CorrId 10) in 100ms
%7|1602442988.056|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.056|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 11)
%7|1602442988.056|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 11, rtt 0.26ms)
%7|1602442988.056|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: AddPartitionsToTxn response: partition "demooutput1602442758": [0]: Broker: Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
%7|1602442988.059|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 9, rtt 5.72ms)
%7|1602442988.059|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 64, LSO 64, Ver 2/2
%7|1602442988.059|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 63, 0 ctrl msgs, uncompressed)
%7|1602442988.059|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 64 (v2)
%7|1602442988.059|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.059|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 10)
%7|1602442988.065|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 10, rtt 5.97ms)
%7|1602442988.065|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 65, LSO 65, Ver 2/2
%7|1602442988.065|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 64, 0 ctrl msgs, uncompressed)
%7|1602442988.065|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 65 (v2)
%7|1602442988.065|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.065|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 11)
%7|1602442988.071|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 11, rtt 6.23ms)
%7|1602442988.071|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 66, LSO 66, Ver 2/2
%7|1602442988.071|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 65, 0 ctrl msgs, uncompressed)
%7|1602442988.071|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 66 (v2)
%7|1602442988.071|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.071|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 12)
%7|1602442988.076|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.076|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 12)
%7|1602442988.077|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 12, rtt 0.66ms)
%7|1602442988.077|ADDPARTS|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0] registered with transaction
%7|1602442988.077|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.077|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1602442988.077|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.077|PRODUCE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: Produce MessageSet with 1 message(s) (76 bytes, ApiVersion 7, MsgVersion 2, MsgId 3, BaseSeq 2, PID{Id:0,Epoch:3}, uncompressed)
%7|1602442988.077|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent ProduceRequest (v7, 168 bytes @ 0, CorrId 11)
%7|1602442988.077|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 12, rtt 6.08ms)
%7|1602442988.077|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 67, LSO 67, Ver 2/2
%7|1602442988.077|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 66, 0 ctrl msgs, uncompressed)
%7|1602442988.077|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 67 (v2)
%7|1602442988.077|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.077|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 13)
%7|1602442988.078|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received ProduceResponse (v7, 70 bytes, CorrId 11, rtt 0.62ms)
%7|1602442988.078|MSGSET|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: MessageSet with 1 message(s) (MsgId 3, BaseSeq 2) delivered
%7|1602442988.083|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 13, rtt 5.82ms)
%7|1602442988.083|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 68, LSO 68, Ver 2/2
%7|1602442988.083|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 67, 0 ctrl msgs, uncompressed)
%7|1602442988.083|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 68 (v2)
%7|1602442988.083|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.083|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 14)
%7|1602442988.089|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 14, rtt 5.95ms)
%7|1602442988.089|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 69, LSO 69, Ver 2/2
%7|1602442988.089|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 68, 0 ctrl msgs, uncompressed)
%7|1602442988.089|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 69 (v2)
%7|1602442988.089|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.089|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 15)
%7|1602442988.095|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 159 bytes, CorrId 15, rtt 5.96ms)
%7|1602442988.095|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 71, error "Success", MaxOffset 70, LSO 70, Ver 2/2
%7|1602442988.095|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (3 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 69, 0 ctrl msgs, uncompressed)
%7|1602442988.095|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 70 (v2)
%7|1602442988.095|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.095|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 16)
%7|1602442988.101|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 16, rtt 6.15ms)
%7|1602442988.101|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 71, LSO 71, Ver 2/2
%7|1602442988.101|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 70, 0 ctrl msgs, uncompressed)
%7|1602442988.101|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 71 (v2)
%7|1602442988.101|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.101|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 17)
%7|1602442988.107|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 17, rtt 5.81ms)
%7|1602442988.107|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 72, LSO 72, Ver 2/2
%7|1602442988.107|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 71, 0 ctrl msgs, uncompressed)
%7|1602442988.107|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 72 (v2)
%7|1602442988.107|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.107|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 18)
%7|1602442988.113|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 18, rtt 5.95ms)
%7|1602442988.113|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 73, LSO 73, Ver 2/2
%7|1602442988.113|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 72, 0 ctrl msgs, uncompressed)
%7|1602442988.113|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 73 (v2)
%7|1602442988.113|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.113|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 19)
%7|1602442988.120|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 19, rtt 6.32ms)
%7|1602442988.120|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 74, LSO 74, Ver 2/2
%7|1602442988.120|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 73, 0 ctrl msgs, uncompressed)
%7|1602442988.120|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 74 (v2)
%7|1602442988.120|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.120|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 20)
%7|1602442988.125|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 20, rtt 5.73ms)
%7|1602442988.125|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 75, LSO 75, Ver 2/2
%7|1602442988.125|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 74, 0 ctrl msgs, uncompressed)
%7|1602442988.125|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 75 (v2)
%7|1602442988.125|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.125|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 21)
%7|1602442988.132|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 21, rtt 6.45ms)
%7|1602442988.132|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 76, LSO 76, Ver 2/2
%7|1602442988.132|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 75, 0 ctrl msgs, uncompressed)
%7|1602442988.132|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 76 (v2)
%7|1602442988.132|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.132|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 22)
%7|1602442988.138|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 22, rtt 6.37ms)
%7|1602442988.138|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 77, LSO 77, Ver 2/2
%7|1602442988.138|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 76, 0 ctrl msgs, uncompressed)
%7|1602442988.138|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 77 (v2)
%7|1602442988.138|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.138|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 23)
%7|1602442988.145|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 23, rtt 6.78ms)
%7|1602442988.145|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 78, LSO 78, Ver 2/2
%7|1602442988.145|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 77, 0 ctrl msgs, uncompressed)
%7|1602442988.145|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 78 (v2)
%7|1602442988.145|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.145|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 24)
%7|1602442988.151|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 24, rtt 6.09ms)
%7|1602442988.151|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 79, LSO 79, Ver 2/2
%7|1602442988.151|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 78, 0 ctrl msgs, uncompressed)
%7|1602442988.151|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 79 (v2)
%7|1602442988.151|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.151|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 25)
%7|1602442988.156|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Moved 1 retry buffer(s) to output queue
%7|1602442988.156|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 13)
%7|1602442988.157|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 13, rtt 0.92ms)
%7|1602442988.157|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent TxnOffsetCommitRequest (v0, 128 bytes @ 0, CorrId 12)
%7|1602442988.158|RECV|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received FetchResponse (v11, 160 bytes, CorrId 25, rtt 6.71ms)
%7|1602442988.158|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Topic demoinput1602442758 [0] MessageSet size 72, error "Success", MaxOffset 80, LSO 80, Ver 2/2
%7|1602442988.158|CONSUME|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Enqueue 1 message(s) (4 bytes, 1 ops) on demoinput1602442758 [0] fetch queue (qlen 1, v2, last_offset 79, 0 ctrl msgs, uncompressed)
%7|1602442988.158|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch topic demoinput1602442758 [0] at offset 80 (v2)
%7|1602442988.158|FETCH|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Fetch 1/1/1 toppar(s)
%7|1602442988.158|SEND|rdkafka#consumer-1| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent FetchRequest (v11, 116 bytes @ 0, CorrId 26)
%7|1602442988.159|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received TxnOffsetCommitResponse (v0, 46 bytes, CorrId 12, rtt 1.43ms)
:DEMO:END 1602442988.1592789 0.10375642776489258
%7|1602442988.159|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction (begin)
%7|1602442988.159|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change InTransaction -> BeginCommit
%7|1602442988.159|TXNCOMMIT|rdkafka#producer-2| [thrd:app]: Flushing 2 outstanding message(s) prior to commit
%7|1602442988.159|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction
%7|1602442988.159|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change BeginCommit -> CommittingTransaction
%7|1602442988.159|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent EndTxnRequest (v1, 53 bytes @ 0, CorrId 14)
%7|1602442988.160|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received EndTxnResponse (v1, 6 bytes, CorrId 14, rtt 0.63ms)
%7|1602442988.160|TXNCOMPLETE|rdkafka#producer-2| [thrd:main]: Transaction successfully committed
%7|1602442988.160|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change CommittingTransaction -> Ready
%7|1602442988.160|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change Ready -> InTransaction
%7|1602442988.160|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.160|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
=== Committing transaction with 1 messages at input offset 63 ===
:DEMO:START 1602442988.1601617
%7|1602442988.160|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
%7|1602442988.160|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: send_offsets_to_transaction
%7|1602442988.160|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 15)
%7|1602442988.161|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 16)
%7|1602442988.161|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.161|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 15, rtt 1.09ms)
%7|1602442988.161|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Retrying AddOffsetsToTxnRequest (v0, 78 bytes, retry 1/3, prev CorrId 15) in 100ms
%7|1602442988.161|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 16, rtt 0.38ms)
%7|1602442988.161|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: AddPartitionsToTxn response: partition "demooutput1602442758": [0]: Broker: Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
%7|1602442988.181|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.181|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 17)
%7|1602442988.183|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 17, rtt 1.44ms)
%7|1602442988.183|ADDPARTS|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0] registered with transaction
%7|1602442988.183|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.183|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.183|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1602442988.183|PRODUCE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: Produce MessageSet with 1 message(s) (76 bytes, ApiVersion 7, MsgVersion 2, MsgId 4, BaseSeq 3, PID{Id:0,Epoch:3}, uncompressed)
%7|1602442988.183|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent ProduceRequest (v7, 168 bytes @ 0, CorrId 13)
%7|1602442988.184|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received ProduceResponse (v7, 70 bytes, CorrId 13, rtt 1.00ms)
%7|1602442988.184|MSGSET|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: MessageSet with 1 message(s) (MsgId 4, BaseSeq 3) delivered
%7|1602442988.262|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Moved 1 retry buffer(s) to output queue
%7|1602442988.262|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 18)
%7|1602442988.263|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 18, rtt 1.05ms)
%7|1602442988.263|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent TxnOffsetCommitRequest (v0, 128 bytes @ 0, CorrId 14)
%7|1602442988.264|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received TxnOffsetCommitResponse (v0, 46 bytes, CorrId 14, rtt 1.24ms)
:DEMO:END 1602442988.2647698 0.10460805892944336
%7|1602442988.264|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction (begin)
%7|1602442988.264|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change InTransaction -> BeginCommit
%7|1602442988.264|TXNCOMMIT|rdkafka#producer-2| [thrd:app]: Flushing 2 outstanding message(s) prior to commit
%7|1602442988.264|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction
%7|1602442988.264|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change BeginCommit -> CommittingTransaction
%7|1602442988.264|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent EndTxnRequest (v1, 53 bytes @ 0, CorrId 19)
%7|1602442988.265|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received EndTxnResponse (v1, 6 bytes, CorrId 19, rtt 0.67ms)
%7|1602442988.265|TXNCOMPLETE|rdkafka#producer-2| [thrd:main]: Transaction successfully committed
%7|1602442988.265|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change CommittingTransaction -> Ready
%7|1602442988.265|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change Ready -> InTransaction
%7|1602442988.265|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.265|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
=== Committing transaction with 1 messages at input offset 64 ===
:DEMO:START 1602442988.2657108
%7|1602442988.265|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "kafka-tr-issue-201011-tr" received op GET_ASSIGNMENT (v0) in state up (join state started, v5 vs 0)
%7|1602442988.265|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: send_offsets_to_transaction
%7|1602442988.265|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 20)
%7|1602442988.266|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 20, rtt 0.30ms)
%7|1602442988.266|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Retrying AddOffsetsToTxnRequest (v0, 78 bytes, retry 1/3, prev CorrId 20) in 100ms
%7|1602442988.266|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.266|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 21)
%7|1602442988.267|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 21, rtt 1.00ms)
%7|1602442988.267|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: AddPartitionsToTxn response: partition "demooutput1602442758": [0]: Broker: Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
%7|1602442988.287|ADDPARTS|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Adding partitions to transaction
%7|1602442988.287|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddPartitionsToTxnRequest (v0, 92 bytes @ 0, CorrId 22)
%7|1602442988.288|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddPartitionsToTxnResponse (v0, 46 bytes, CorrId 22, rtt 0.94ms)
%7|1602442988.288|ADDPARTS|rdkafka#producer-2| [thrd:main]: demooutput1602442758 [0] registered with transaction
%7|1602442988.288|WAKEUP|rdkafka#producer-2| [thrd:main]: 172.31.31.3:9092/1001: Wake-up
%7|1602442988.288|TOPPAR|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1602442988.288|PRODUCE|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: Produce MessageSet with 1 message(s) (76 bytes, ApiVersion 7, MsgVersion 2, MsgId 5, BaseSeq 4, PID{Id:0,Epoch:3}, uncompressed)
%7|1602442988.288|WAKEUP|rdkafka#producer-2| [thrd:main]: TxnCoordinator/1001: Wake-up
%7|1602442988.288|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent ProduceRequest (v7, 168 bytes @ 0, CorrId 15)
%7|1602442988.289|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received ProduceResponse (v7, 70 bytes, CorrId 15, rtt 0.73ms)
%7|1602442988.289|MSGSET|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: demooutput1602442758 [0]: MessageSet with 1 message(s) (MsgId 5, BaseSeq 4) delivered
%7|1602442988.366|RETRY|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Moved 1 retry buffer(s) to output queue
%7|1602442988.367|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent AddOffsetsToTxnRequest (v0, 78 bytes @ 0, CorrId 23)
%7|1602442988.368|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received AddOffsetsToTxnResponse (v0, 6 bytes, CorrId 23, rtt 1.12ms)
%7|1602442988.368|SEND|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Sent TxnOffsetCommitRequest (v0, 128 bytes @ 0, CorrId 16)
%7|1602442988.369|RECV|rdkafka#producer-2| [thrd:172.31.31.3:9092/bootstrap]: 172.31.31.3:9092/1001: Received TxnOffsetCommitResponse (v0, 46 bytes, CorrId 16, rtt 1.14ms)
:DEMO:END 1602442988.3694053 0.10369443893432617
%7|1602442988.369|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction (begin)
%7|1602442988.369|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change InTransaction -> BeginCommit
%7|1602442988.369|TXNCOMMIT|rdkafka#producer-2| [thrd:app]: Flushing 2 outstanding message(s) prior to commit
%7|1602442988.369|TXNAPI|rdkafka#producer-2| [thrd:app]: Transactional API called: commit_transaction
%7|1602442988.369|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change BeginCommit -> CommittingTransaction
%7|1602442988.369|SEND|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Sent EndTxnRequest (v1, 53 bytes @ 0, CorrId 24)
%7|1602442988.370|RECV|rdkafka#producer-2| [thrd:TxnCoordinator]: TxnCoordinator/1001: Received EndTxnResponse (v1, 6 bytes, CorrId 24, rtt 0.63ms)
%7|1602442988.370|TXNCOMPLETE|rdkafka#producer-2| [thrd:main]: Transaction successfully committed
%7|1602442988.370|TXNSTATE|rdkafka#producer-2| [thrd:main]: Transaction state change CommittingTransaction -> Ready