05OCT2024_11:07:39.792 C7D91B40 INFO CONNECT 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: broker in state TRY_CONNECT connecting 05OCT2024_11:07:39.792 C7D91B40 INFO STATE 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Broker changed state INIT -> TRY_CONNECT 05OCT2024_11:07:39.792 C7D91B40 INFO STATE 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Broker changed state TRY_CONNECT -> CONNECT 05OCT2024_11:07:39.792 E07F7B40 INFO BARRIER 7: [thrd:app]: my-topic [0]: rd_kafka_toppar_op_fetch_start:2219: new version barrier v2 { open_persistent_connections 94a4377b-cd37-4e5e-9b03-1245ac4c3c54 } 05OCT2024_11:07:39.792 E07F7B40 INFO CONSUMER 7: [thrd:app]: Start consuming my-topic [0] at offset STORED (leader epoch -1) (v2) { open_persistent_connections 94a4377b-cd37-4e5e-9b03-1245ac4c3c54 } 05OCT2024_11:07:39.792 E07F7B40 INFO DESIRED 7: [thrd:app]: my-topic [0]: marking as DESIRED { open_persistent_connections 94a4377b-cd37-4e5e-9b03-1245ac4c3c54 } 05OCT2024_11:07:39.792 E07F7B40 INFO START 7: [thrd:app]: Start consuming partition 0 { open_persistent_connections 94a4377b-cd37-4e5e-9b03-1245ac4c3c54 } 05OCT2024_11:07:39.792 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_FETCH in state up (join-state init) for my-topic [0] 05OCT2024_11:07:39.792 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op PARTITION_JOIN in state up (join-state init) for my-topic [0] 05OCT2024_11:07:39.792 EDDFFB40 INFO FETCH 7: [thrd:main]: Start fetch for my-topic [0] in state none at offset STORED (leader epoch -1) (v2) 05OCT2024_11:07:39.792 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Group mygroup OffsetFetchRequest(v8) for 1/1 partition(s) 05OCT2024_11:07:39.792 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset reset (at offset STORED (leader epoch -1), broker -1) to offset STORED (leader epoch -1): query broker for offsets: Success 05OCT2024_11:07:39.792 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: using offset store method: broker 05OCT2024_11:07:39.792 EDDFFB40 INFO OFFSETREQ 7: [thrd:main]: Partition my-topic [0]: querying cgrp for committed offset (opv 2) 05OCT2024_11:07:39.792 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op FETCH_START (v2) in fetch-state none (opv1) 05OCT2024_11:07:39.792 EDDFFB40 INFO PARTADD 7: [thrd:main]: Group "mygroup": add my-topic [0] 05OCT2024_11:07:39.792 EDDFFB40 INFO PARTSTATE 7: [thrd:main]: Partition my-topic [0] changed fetch state none -> offset-query 05OCT2024_11:07:39.792 EDDFFB40 INFO PARTSTATE 7: [thrd:main]: Partition my-topic [0] changed fetch state offset-query -> offset-wait 05OCT2024_11:07:39.793 C7D91B40 INFO CONNECT 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Connecting to ipv4#1.2.3.4:9092 (plaintext) with socket 54 05OCT2024_11:07:39.793 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Fetch committed offsets for 1/1 partition(s) 05OCT2024_11:07:39.795 C7D91B40 INFO CONNECT 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Connected to ipv4#1.2.3.4:9092 05OCT2024_11:07:39.795 C7D91B40 INFO CONNECTED 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Connected (#1) 05OCT2024_11:07:39.795 C7D91B40 INFO FEATURE 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Updated enabled protocol features +ApiVersion to ApiVersion 05OCT2024_11:07:39.795 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Topic my-topic [0] in state active at offset 96007 (leader epoch 1732) (0/100000 msgs, 0/65536 kb queued, opv 2) is fetchable 05OCT2024_11:07:39.795 C7D91B40 INFO FETCHADD 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Added my-topic [0] to fetch list (1 entries, opv 2, 0 messages queued): fetchable 05OCT2024_11:07:39.795 C7D91B40 INFO FETCHDEC 7: [thrd:kafka-broker:9092/33223]: Topic my-topic [0]: fetch decide: updating to version 2 (was 0) at offset 96007 (leader epoch 1732) (was offset 0 (leader epoch -1)) 05OCT2024_11:07:39.795 C7D91B40 INFO STATE 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Broker changed state CONNECT -> APIVERSION_QUERY 05OCT2024_11:07:39.795 EDDFFB40 INFO FETCH 7: [thrd:main]: Partition my-topic [0] start fetching at offset 96007 (leader epoch 1732) 05OCT2024_11:07:39.795 EDDFFB40 INFO OFFFETCH 7: [thrd:main]: GroupCoordinator/54475: OffsetFetch for 1/1 partition(s) (0 unstable partition(s)) returned Success 05OCT2024_11:07:39.795 EDDFFB40 INFO OFFSET 7: [thrd:main]: Topic my-topic [0]: setting default offset INVALID (leader epoch -1) 05OCT2024_11:07:39.795 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: OffsetFetch returned offset 96007 (leader epoch 1732) 05OCT2024_11:07:39.795 EDDFFB40 INFO OFFSETFETCH 7: [thrd:main]: GroupCoordinator/54475: OffsetFetchResponse: my-topic [0] offset 96007, leader epoch 1732, metadata 0 byte(s): NO_ERROR 05OCT2024_11:07:39.795 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_FETCH (v2) in fetch-state offset-wait (opv2) 05OCT2024_11:07:39.795 EDDFFB40 INFO PARTSTATE 7: [thrd:main]: Partition my-topic [0] changed fetch state offset-wait -> active 05OCT2024_11:07:39.797 C7D91B40 INFO FEATURE 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq 05OCT2024_11:07:39.797 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:39.797 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96007 (leader epoch 1732, current leader epoch 1738, v2) 05OCT2024_11:07:39.797 C7D91B40 INFO OFFSET 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: ListOffsetsRequest (v7, opv 0) for 1 topic(s) and 1 partition(s) 05OCT2024_11:07:39.797 C7D91B40 INFO OFFSET 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: ListOffsetsRequest (v7, opv 0) for 1 topic(s) and 1 partition(s) 05OCT2024_11:07:39.797 C7D91B40 INFO STATE 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Broker changed state APIVERSION_QUERY -> UP 05OCT2024_11:07:39.802 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 3 message(s) (868 bytes, 3 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96009, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:39.802 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:39.802 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:39.802 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:39.802 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:39.802 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:39.802 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96008 (leader epoch 1738) > committed offset 96007 (leader epoch 1732)? 05OCT2024_11:07:39.802 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96008 (leader epoch 1738): auto commit timer 05OCT2024_11:07:39.809 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:39.809 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96008 committed: Success 05OCT2024_11:07:39.809 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:39.813 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:39.813 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:39.813 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:39.813 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96009 (leader epoch 1738) > committed offset 96008 (leader epoch 1738)? 05OCT2024_11:07:39.813 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96009 (leader epoch 1738): auto commit timer 05OCT2024_11:07:39.819 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:39.819 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96009 committed: Success 05OCT2024_11:07:39.819 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:39.823 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:39.823 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:39.823 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:39.823 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96010 (leader epoch 1738) > committed offset 96009 (leader epoch 1738)? 05OCT2024_11:07:39.823 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96010 (leader epoch 1738): auto commit timer 05OCT2024_11:07:39.829 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:39.829 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96010 committed: Success 05OCT2024_11:07:39.829 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:39.834 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96010 (leader epoch 1738) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:40.304 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:40.304 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:40.304 C7D91B40 INFO FETCHERR 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: my-topic [0]: Fetch failed at offset 96010 (leader epoch 1738): _PARTITION_EOF 05OCT2024_11:07:40.305 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:40.806 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:40.806 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:40.806 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:41.309 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:41.309 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:41.317 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:41.811 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:41.811 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:41.818 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:42.313 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:42.313 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:42.318 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:42.816 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:42.816 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:42.819 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:43.318 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:43.319 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:43.320 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:43.821 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:43.821 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:43.830 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:44.323 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:44.323 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:44.331 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:44.825 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:44.825 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96010 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:44.831 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:45.116 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (137 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96010, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.116 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.116 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96011 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.120 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96011 (leader epoch 0) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:45.143 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96011, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.143 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.143 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96012 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.150 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.150 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.150 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.150 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96012 (leader epoch 1738) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:45.150 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96012 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.160 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96012 (leader epoch 1738) > committed offset 96010 (leader epoch 1738)? 05OCT2024_11:07:45.165 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.165 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96012 committed: Success 05OCT2024_11:07:45.165 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.167 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (137 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96012, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.167 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.167 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96013 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.171 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.171 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.171 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.171 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96013 (leader epoch 1738) > committed offset 96012 (leader epoch 1738)? 05OCT2024_11:07:45.171 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96013 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.174 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96013, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.174 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.174 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96014 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.177 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.177 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96013 committed: Success 05OCT2024_11:07:45.177 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.182 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.182 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.182 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.182 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96014 (leader epoch 1738) > committed offset 96013 (leader epoch 1738)? 05OCT2024_11:07:45.182 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96014 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.188 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.188 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96014 committed: Success 05OCT2024_11:07:45.188 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.191 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (137 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96014, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.191 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.191 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96015 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.193 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.193 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.193 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.193 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96015 (leader epoch 1738) > committed offset 96014 (leader epoch 1738)? 05OCT2024_11:07:45.193 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96015 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.199 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.199 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96015 committed: Success 05OCT2024_11:07:45.199 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.202 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (137 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96015, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.202 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.202 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96016 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.203 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.203 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.203 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.203 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96016 (leader epoch 1738) > committed offset 96015 (leader epoch 1738)? 05OCT2024_11:07:45.203 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96016 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.209 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.209 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96016 committed: Success 05OCT2024_11:07:45.209 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.214 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96016 (leader epoch 1738) > committed offset 96016 (leader epoch 1738)? 05OCT2024_11:07:45.218 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (137 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96016, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.218 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.218 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96017 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.225 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.225 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.225 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.225 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96017 (leader epoch 1738) > committed offset 96016 (leader epoch 1738)? 05OCT2024_11:07:45.225 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96017 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.229 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (137 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96017, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.229 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.229 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96018 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.230 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.231 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96017 committed: Success 05OCT2024_11:07:45.231 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.235 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.235 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.235 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.235 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96018 (leader epoch 1738) > committed offset 96017 (leader epoch 1738)? 05OCT2024_11:07:45.235 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96018 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.241 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.241 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96018 committed: Success 05OCT2024_11:07:45.241 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.245 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96018 (leader epoch 1738) > committed offset 96018 (leader epoch 1738)? 05OCT2024_11:07:45.247 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96018, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.247 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.247 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96019 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.255 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.255 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.255 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.255 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96019 (leader epoch 1738) > committed offset 96018 (leader epoch 1738)? 05OCT2024_11:07:45.255 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96019 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.257 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96019, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.257 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.257 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96020 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.262 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.262 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96019 committed: Success 05OCT2024_11:07:45.262 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.266 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.266 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.266 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.266 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96020 (leader epoch 1738) > committed offset 96019 (leader epoch 1738)? 05OCT2024_11:07:45.266 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96020 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.272 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.272 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96020 committed: Success 05OCT2024_11:07:45.272 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.276 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96020, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.276 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.276 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96021 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.276 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.276 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.276 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.276 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96021 (leader epoch 1738) > committed offset 96020 (leader epoch 1738)? 05OCT2024_11:07:45.276 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96021 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.282 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.282 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96021 committed: Success 05OCT2024_11:07:45.282 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.287 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96021 (leader epoch 1738) > committed offset 96021 (leader epoch 1738)? 05OCT2024_11:07:45.289 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96021, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.289 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.289 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96022 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.298 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.298 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.298 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.298 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96022 (leader epoch 1738) > committed offset 96021 (leader epoch 1738)? 05OCT2024_11:07:45.298 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96022 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.303 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96022, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.303 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.303 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96023 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.303 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.303 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.304 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96022 committed: Success 05OCT2024_11:07:45.308 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.308 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.308 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.308 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96023 (leader epoch 1738) > committed offset 96022 (leader epoch 1738)? 05OCT2024_11:07:45.308 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96023 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.313 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.313 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96023 committed: Success 05OCT2024_11:07:45.313 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.319 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96023, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.319 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.319 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96024 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.319 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.319 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.319 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.319 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96024 (leader epoch 1738) > committed offset 96023 (leader epoch 1738)? 05OCT2024_11:07:45.319 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96024 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.325 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.325 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96024 committed: Success 05OCT2024_11:07:45.325 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.329 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96024 (leader epoch 1738) > committed offset 96024 (leader epoch 1738)? 05OCT2024_11:07:45.336 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96024, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.336 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.336 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96025 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.339 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.339 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.339 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.339 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96025 (leader epoch 1738) > committed offset 96024 (leader epoch 1738)? 05OCT2024_11:07:45.339 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96025 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.345 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.345 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96025 committed: Success 05OCT2024_11:07:45.345 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.350 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96025, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.350 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.350 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96026 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.350 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96025 (leader epoch 1738) > committed offset 96025 (leader epoch 1738)? 05OCT2024_11:07:45.360 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.360 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.360 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.360 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96026 (leader epoch 1738) > committed offset 96025 (leader epoch 1738)? 05OCT2024_11:07:45.360 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96026 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.363 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96026, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.363 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.363 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96027 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.366 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.366 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96026 committed: Success 05OCT2024_11:07:45.366 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.370 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.370 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.370 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.370 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96027 (leader epoch 1738) > committed offset 96026 (leader epoch 1738)? 05OCT2024_11:07:45.370 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96027 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.376 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.376 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96027 committed: Success 05OCT2024_11:07:45.376 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.377 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96027, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.377 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.377 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96028 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.380 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96028 (leader epoch 1738) > committed offset 96027 (leader epoch 1738)? 05OCT2024_11:07:45.380 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96028 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.381 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.381 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.381 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.387 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.387 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96028 committed: Success 05OCT2024_11:07:45.387 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.391 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96028, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.391 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.391 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96029 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.391 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96028 (leader epoch 1738) > committed offset 96028 (leader epoch 1738)? 05OCT2024_11:07:45.401 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.401 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.401 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.401 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96029 (leader epoch 1738) > committed offset 96028 (leader epoch 1738)? 05OCT2024_11:07:45.401 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96029 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.405 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96029, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.405 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.405 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96030 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.407 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.407 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96029 committed: Success 05OCT2024_11:07:45.407 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.412 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.412 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.412 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.412 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96030 (leader epoch 1738) > committed offset 96029 (leader epoch 1738)? 05OCT2024_11:07:45.412 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96030 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.418 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96030, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.418 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.418 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96031 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.418 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.418 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96030 committed: Success 05OCT2024_11:07:45.418 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.422 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.422 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.422 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.422 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96031 (leader epoch 1738) > committed offset 96030 (leader epoch 1738)? 05OCT2024_11:07:45.422 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96031 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.429 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.429 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96031 committed: Success 05OCT2024_11:07:45.429 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.433 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96031 (leader epoch 1738) > committed offset 96031 (leader epoch 1738)? 05OCT2024_11:07:45.436 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96031, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.436 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.436 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96032 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.443 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.443 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.443 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.443 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96032 (leader epoch 1738) > committed offset 96031 (leader epoch 1738)? 05OCT2024_11:07:45.443 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96032 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.449 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96032, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.449 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.449 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96033 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.449 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.449 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96032 committed: Success 05OCT2024_11:07:45.449 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.453 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96033 (leader epoch 1738) > committed offset 96032 (leader epoch 1738)? 05OCT2024_11:07:45.454 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.454 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.454 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.454 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96033 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.460 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.460 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96033 committed: Success 05OCT2024_11:07:45.460 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.463 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96033, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.463 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.463 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96034 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.464 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.464 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.464 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.464 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96034 (leader epoch 1738) > committed offset 96033 (leader epoch 1738)? 05OCT2024_11:07:45.464 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96034 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.471 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.471 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96034 committed: Success 05OCT2024_11:07:45.471 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.475 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96034, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.475 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.475 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96035 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.475 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.475 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.475 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.475 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96035 (leader epoch 1738) > committed offset 96034 (leader epoch 1738)? 05OCT2024_11:07:45.475 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96035 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.481 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.481 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96035 committed: Success 05OCT2024_11:07:45.481 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.485 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96035 (leader epoch 1738) > committed offset 96035 (leader epoch 1738)? 05OCT2024_11:07:45.488 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96035, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.488 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.488 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96036 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.495 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.495 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.495 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.495 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96036 (leader epoch 1738) > committed offset 96035 (leader epoch 1738)? 05OCT2024_11:07:45.495 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96036 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.500 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96036, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.501 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.501 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96037 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.501 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.501 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96036 committed: Success 05OCT2024_11:07:45.501 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.506 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.506 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.506 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.506 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96037 (leader epoch 1738) > committed offset 96036 (leader epoch 1738)? 05OCT2024_11:07:45.506 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96037 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.512 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.512 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96037 committed: Success 05OCT2024_11:07:45.512 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.513 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96037, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.513 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.513 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96038 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.517 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.517 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.517 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.517 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96038 (leader epoch 1738) > committed offset 96037 (leader epoch 1738)? 05OCT2024_11:07:45.517 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96038 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.518 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96038, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.518 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.518 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96039 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.524 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.524 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96038 committed: Success 05OCT2024_11:07:45.524 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.526 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96039, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.526 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.526 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96040 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.528 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.528 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.528 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.528 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96040 (leader epoch 1738) > committed offset 96038 (leader epoch 1738)? 05OCT2024_11:07:45.528 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96040 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.535 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.535 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96040 committed: Success 05OCT2024_11:07:45.535 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.539 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96040 (leader epoch 1738) > committed offset 96040 (leader epoch 1738)? 05OCT2024_11:07:45.543 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96040, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.543 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.543 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96041 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.549 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.549 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.549 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.549 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96041 (leader epoch 1738) > committed offset 96040 (leader epoch 1738)? 05OCT2024_11:07:45.549 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96041 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.554 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96041, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.554 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.554 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96042 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.555 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.555 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96041 committed: Success 05OCT2024_11:07:45.555 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.559 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.559 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.559 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.559 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96042 (leader epoch 1738) > committed offset 96041 (leader epoch 1738)? 05OCT2024_11:07:45.559 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96042 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.565 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.566 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96042 committed: Success 05OCT2024_11:07:45.566 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.570 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96042, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.570 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.570 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96043 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.570 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96042 (leader epoch 1738) > committed offset 96042 (leader epoch 1738)? 05OCT2024_11:07:45.580 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.580 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.580 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.580 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96043 (leader epoch 1738) > committed offset 96042 (leader epoch 1738)? 05OCT2024_11:07:45.580 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96043 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.582 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96043, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.582 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.582 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96044 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.586 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.586 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96043 committed: Success 05OCT2024_11:07:45.586 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.590 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.590 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.590 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.590 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96044 (leader epoch 1738) > committed offset 96043 (leader epoch 1738)? 05OCT2024_11:07:45.590 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96044 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.595 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96044, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.595 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.595 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96045 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.596 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.596 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96044 committed: Success 05OCT2024_11:07:45.596 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.601 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.601 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.601 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.601 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96045 (leader epoch 1738) > committed offset 96044 (leader epoch 1738)? 05OCT2024_11:07:45.601 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96045 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.606 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.606 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96045 committed: Success 05OCT2024_11:07:45.606 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.611 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96045 (leader epoch 1738) > committed offset 96045 (leader epoch 1738)? 05OCT2024_11:07:45.612 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96045, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.612 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.612 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96046 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.621 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.621 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.621 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.621 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96046 (leader epoch 1738) > committed offset 96045 (leader epoch 1738)? 05OCT2024_11:07:45.621 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96046 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.627 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96046, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.627 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.627 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96047 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.627 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.627 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96046 committed: Success 05OCT2024_11:07:45.627 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.631 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.631 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.631 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.631 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96047 (leader epoch 1738) > committed offset 96046 (leader epoch 1738)? 05OCT2024_11:07:45.631 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96047 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.637 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.637 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96047 committed: Success 05OCT2024_11:07:45.637 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.638 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96047, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.638 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.638 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96048 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.642 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.642 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.642 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.642 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96048 (leader epoch 1738) > committed offset 96047 (leader epoch 1738)? 05OCT2024_11:07:45.642 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96048 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.648 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.648 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96048 committed: Success 05OCT2024_11:07:45.648 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.652 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96048, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.652 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.652 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96049 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.653 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.653 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.653 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.653 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96049 (leader epoch 1738) > committed offset 96048 (leader epoch 1738)? 05OCT2024_11:07:45.653 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96049 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.659 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.659 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96049 committed: Success 05OCT2024_11:07:45.659 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.663 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96049 (leader epoch 1738) > committed offset 96049 (leader epoch 1738)? 05OCT2024_11:07:45.665 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96049, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.665 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.665 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96050 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.673 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.673 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.673 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.673 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96050 (leader epoch 1738) > committed offset 96049 (leader epoch 1738)? 05OCT2024_11:07:45.673 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96050 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.678 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96050, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.678 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.678 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96051 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.679 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.679 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96050 committed: Success 05OCT2024_11:07:45.679 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.684 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.684 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.684 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.684 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96051 (leader epoch 1738) > committed offset 96050 (leader epoch 1738)? 05OCT2024_11:07:45.684 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96051 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.690 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.690 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96051 committed: Success 05OCT2024_11:07:45.690 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.694 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96051, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.694 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.694 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96052 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.694 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.694 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.694 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.694 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96052 (leader epoch 1738) > committed offset 96051 (leader epoch 1738)? 05OCT2024_11:07:45.694 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96052 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.700 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.700 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96052 committed: Success 05OCT2024_11:07:45.700 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.704 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96052 (leader epoch 1738) > committed offset 96052 (leader epoch 1738)? 05OCT2024_11:07:45.707 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96052, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.708 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.708 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96053 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.714 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.714 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.714 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.714 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96053 (leader epoch 1738) > committed offset 96052 (leader epoch 1738)? 05OCT2024_11:07:45.714 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96053 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.721 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96053, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.721 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.721 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96054 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.721 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.721 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96053 committed: Success 05OCT2024_11:07:45.721 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.724 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.724 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.724 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.724 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96054 (leader epoch 1738) > committed offset 96053 (leader epoch 1738)? 05OCT2024_11:07:45.724 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96054 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.730 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.730 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96054 committed: Success 05OCT2024_11:07:45.730 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.735 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96054, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.735 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.735 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96055 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.735 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.735 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.735 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.735 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96055 (leader epoch 1738) > committed offset 96054 (leader epoch 1738)? 05OCT2024_11:07:45.735 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96055 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.741 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.741 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96055 committed: Success 05OCT2024_11:07:45.741 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.746 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96055 (leader epoch 1738) > committed offset 96055 (leader epoch 1738)? 05OCT2024_11:07:45.748 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96055, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.749 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.749 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96056 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.756 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.756 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.756 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.756 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96056 (leader epoch 1738) > committed offset 96055 (leader epoch 1738)? 05OCT2024_11:07:45.756 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96056 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.762 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.762 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96056 committed: Success 05OCT2024_11:07:45.762 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.763 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96056, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.763 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.763 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96057 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.766 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.766 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.766 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.766 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96057 (leader epoch 1738) > committed offset 96056 (leader epoch 1738)? 05OCT2024_11:07:45.766 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96057 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.773 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.773 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96057 committed: Success 05OCT2024_11:07:45.773 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.777 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96057 (leader epoch 1738) > committed offset 96057 (leader epoch 1738)? 05OCT2024_11:07:45.778 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96057, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.778 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.778 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96058 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.787 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.787 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.787 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.787 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96058 (leader epoch 1738) > committed offset 96057 (leader epoch 1738)? 05OCT2024_11:07:45.787 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96058 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.792 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96058, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.792 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.792 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96059 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.794 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.794 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96058 committed: Success 05OCT2024_11:07:45.794 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.797 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.797 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.797 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.797 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96059 (leader epoch 1738) > committed offset 96058 (leader epoch 1738)? 05OCT2024_11:07:45.797 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96059 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.803 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.804 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96059 committed: Success 05OCT2024_11:07:45.804 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.806 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96059, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.806 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.806 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96060 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.808 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.808 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.808 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.808 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96060 (leader epoch 1738) > committed offset 96059 (leader epoch 1738)? 05OCT2024_11:07:45.808 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96060 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.814 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.814 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96060 committed: Success 05OCT2024_11:07:45.814 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.818 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96060 (leader epoch 1738) > committed offset 96060 (leader epoch 1738)? 05OCT2024_11:07:45.820 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96060, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.820 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.820 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96061 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.828 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.828 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.828 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.828 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96061 (leader epoch 1738) > committed offset 96060 (leader epoch 1738)? 05OCT2024_11:07:45.828 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96061 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.834 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96061, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.834 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.834 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96062 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.834 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.834 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96061 committed: Success 05OCT2024_11:07:45.834 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.838 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96062 (leader epoch 1738) > committed offset 96061 (leader epoch 1738)? 05OCT2024_11:07:45.839 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.839 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.839 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.839 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96062 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.844 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.844 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96062 committed: Success 05OCT2024_11:07:45.844 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.848 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96062, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.848 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.848 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96063 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.849 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.849 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.849 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.849 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96063 (leader epoch 1738) > committed offset 96062 (leader epoch 1738)? 05OCT2024_11:07:45.849 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96063 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.855 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.855 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96063 committed: Success 05OCT2024_11:07:45.855 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.860 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96063 (leader epoch 1738) > committed offset 96063 (leader epoch 1738)? 05OCT2024_11:07:45.863 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96063, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.863 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.863 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96064 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.871 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.871 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.871 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.871 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96064 (leader epoch 1738) > committed offset 96063 (leader epoch 1738)? 05OCT2024_11:07:45.871 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96064 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.877 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96064, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.877 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.877 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96065 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.877 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.877 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96064 committed: Success 05OCT2024_11:07:45.877 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.881 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.881 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.881 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.881 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96065 (leader epoch 1738) > committed offset 96064 (leader epoch 1738)? 05OCT2024_11:07:45.881 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96065 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.888 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.888 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96065 committed: Success 05OCT2024_11:07:45.888 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.890 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96065, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.890 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96066 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.891 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.892 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.892 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.892 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.892 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96066 (leader epoch 1738) > committed offset 96065 (leader epoch 1738)? 05OCT2024_11:07:45.892 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96066 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.898 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.898 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96066 committed: Success 05OCT2024_11:07:45.898 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.902 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96066 (leader epoch 1738) > committed offset 96066 (leader epoch 1738)? 05OCT2024_11:07:45.904 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96066, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.904 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.904 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96067 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.912 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.912 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.912 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.912 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96067 (leader epoch 1738) > committed offset 96066 (leader epoch 1738)? 05OCT2024_11:07:45.912 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96067 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.918 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96067, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.918 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.918 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96068 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.918 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.918 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96067 committed: Success 05OCT2024_11:07:45.918 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.923 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.923 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.923 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.923 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96068 (leader epoch 1738) > committed offset 96067 (leader epoch 1738)? 05OCT2024_11:07:45.923 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96068 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.929 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.929 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96068 committed: Success 05OCT2024_11:07:45.929 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.932 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96068, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.932 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.932 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96069 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.933 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.933 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.933 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.933 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96069 (leader epoch 1738) > committed offset 96068 (leader epoch 1738)? 05OCT2024_11:07:45.933 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96069 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.939 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.939 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96069 committed: Success 05OCT2024_11:07:45.939 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.944 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96069 (leader epoch 1738) > committed offset 96069 (leader epoch 1738)? 05OCT2024_11:07:45.946 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96069, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.946 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.946 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96070 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.954 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.954 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.954 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.954 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96070 (leader epoch 1738) > committed offset 96069 (leader epoch 1738)? 05OCT2024_11:07:45.954 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96070 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.959 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96070, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.959 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.959 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96071 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.960 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.961 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96070 committed: Success 05OCT2024_11:07:45.961 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.965 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.965 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.965 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.965 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96071 (leader epoch 1738) > committed offset 96070 (leader epoch 1738)? 05OCT2024_11:07:45.965 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96071 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.972 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.972 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96071 committed: Success 05OCT2024_11:07:45.972 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.974 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96071, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.974 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.974 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96072 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.975 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.975 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.975 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.975 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96072 (leader epoch 1738) > committed offset 96071 (leader epoch 1738)? 05OCT2024_11:07:45.975 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96072 (leader epoch 1738): auto commit timer 05OCT2024_11:07:45.981 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:45.981 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96072 committed: Success 05OCT2024_11:07:45.981 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:45.985 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96072 (leader epoch 1738) > committed offset 96072 (leader epoch 1738)? 05OCT2024_11:07:45.987 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96072, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:45.987 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:45.987 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96073 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:45.996 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:45.996 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:45.996 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:45.996 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96073 (leader epoch 1738) > committed offset 96072 (leader epoch 1738)? 05OCT2024_11:07:45.996 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96073 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.000 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96073, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.000 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.000 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96074 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.002 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.002 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96073 committed: Success 05OCT2024_11:07:46.002 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.006 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.006 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.006 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.006 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96074 (leader epoch 1738) > committed offset 96073 (leader epoch 1738)? 05OCT2024_11:07:46.006 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96074 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.012 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.012 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96074 committed: Success 05OCT2024_11:07:46.012 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.014 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96074, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.014 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.014 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96075 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.016 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.016 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.016 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.016 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96075 (leader epoch 1738) > committed offset 96074 (leader epoch 1738)? 05OCT2024_11:07:46.016 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96075 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.023 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.023 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96075 committed: Success 05OCT2024_11:07:46.023 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.027 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96075 (leader epoch 1738) > committed offset 96075 (leader epoch 1738)? 05OCT2024_11:07:46.029 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96075, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.029 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.029 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96076 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.037 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.037 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.037 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.037 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96076 (leader epoch 1738) > committed offset 96075 (leader epoch 1738)? 05OCT2024_11:07:46.037 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96076 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.042 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96076, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.042 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.042 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96077 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.043 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.043 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96076 committed: Success 05OCT2024_11:07:46.043 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.048 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.048 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.048 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.048 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96077 (leader epoch 1738) > committed offset 96076 (leader epoch 1738)? 05OCT2024_11:07:46.048 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96077 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.054 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.054 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96077 committed: Success 05OCT2024_11:07:46.054 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.059 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96077, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.059 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.059 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96078 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.059 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.059 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.059 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.059 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96078 (leader epoch 1738) > committed offset 96077 (leader epoch 1738)? 05OCT2024_11:07:46.059 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96078 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.065 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.065 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96078 committed: Success 05OCT2024_11:07:46.065 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.069 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96078 (leader epoch 1738) > committed offset 96078 (leader epoch 1738)? 05OCT2024_11:07:46.070 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96078, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.070 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.070 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96079 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.079 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.079 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.079 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.079 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96079 (leader epoch 1738) > committed offset 96078 (leader epoch 1738)? 05OCT2024_11:07:46.079 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96079 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.083 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96079, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.084 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.084 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96080 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.085 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.085 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96079 committed: Success 05OCT2024_11:07:46.085 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.090 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.090 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.090 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.090 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96080 (leader epoch 1738) > committed offset 96079 (leader epoch 1738)? 05OCT2024_11:07:46.090 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96080 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.096 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96080, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.096 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.096 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96081 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.096 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.096 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96080 committed: Success 05OCT2024_11:07:46.096 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.100 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.100 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.100 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.100 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96081 (leader epoch 1738) > committed offset 96080 (leader epoch 1738)? 05OCT2024_11:07:46.100 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96081 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.106 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.106 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96081 committed: Success 05OCT2024_11:07:46.106 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.110 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96081, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.110 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.110 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96082 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.110 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.110 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.110 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.110 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96082 (leader epoch 1738) > committed offset 96081 (leader epoch 1738)? 05OCT2024_11:07:46.110 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96082 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.116 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.116 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96082 committed: Success 05OCT2024_11:07:46.116 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.121 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96082 (leader epoch 1738) > committed offset 96082 (leader epoch 1738)? 05OCT2024_11:07:46.124 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96082, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.124 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.124 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96083 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.131 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.131 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.131 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.131 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96083 (leader epoch 1738) > committed offset 96082 (leader epoch 1738)? 05OCT2024_11:07:46.131 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96083 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.137 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96083, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.137 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.137 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96084 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.138 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.138 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96083 committed: Success 05OCT2024_11:07:46.138 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.142 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.142 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.142 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.142 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96084 (leader epoch 1738) > committed offset 96083 (leader epoch 1738)? 05OCT2024_11:07:46.142 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96084 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.147 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.148 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96084 committed: Success 05OCT2024_11:07:46.148 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.153 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96084 (leader epoch 1738) > committed offset 96084 (leader epoch 1738)? 05OCT2024_11:07:46.158 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96084, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.158 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.158 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96085 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.162 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96085, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.162 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.162 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96086 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.163 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.163 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.163 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.163 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96086 (leader epoch 1738) > committed offset 96084 (leader epoch 1738)? 05OCT2024_11:07:46.163 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96086 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.169 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.169 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96086 committed: Success 05OCT2024_11:07:46.169 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.173 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96086 (leader epoch 1738) > committed offset 96086 (leader epoch 1738)? 05OCT2024_11:07:46.175 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96086, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.175 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.175 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96087 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.184 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.184 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.184 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.184 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96087 (leader epoch 1738) > committed offset 96086 (leader epoch 1738)? 05OCT2024_11:07:46.184 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96087 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.188 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96087, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.188 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.188 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96088 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.190 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.190 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96087 committed: Success 05OCT2024_11:07:46.190 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.194 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.194 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.194 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.194 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96088 (leader epoch 1738) > committed offset 96087 (leader epoch 1738)? 05OCT2024_11:07:46.194 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96088 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.200 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.200 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96088 committed: Success 05OCT2024_11:07:46.200 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.202 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96088, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.202 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.202 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96089 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.204 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.204 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.204 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.204 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96089 (leader epoch 1738) > committed offset 96088 (leader epoch 1738)? 05OCT2024_11:07:46.204 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96089 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.210 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.210 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96089 committed: Success 05OCT2024_11:07:46.210 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.215 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96089, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.215 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.215 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96090 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.215 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96089 (leader epoch 1738) > committed offset 96089 (leader epoch 1738)? 05OCT2024_11:07:46.225 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.225 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.225 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.225 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96090 (leader epoch 1738) > committed offset 96089 (leader epoch 1738)? 05OCT2024_11:07:46.225 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96090 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.230 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96090, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.230 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.230 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96091 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.231 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.231 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96090 committed: Success 05OCT2024_11:07:46.231 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.235 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.235 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.235 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.235 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96091 (leader epoch 1738) > committed offset 96090 (leader epoch 1738)? 05OCT2024_11:07:46.235 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96091 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.242 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (139 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96091, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.242 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.242 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96091 committed: Success 05OCT2024_11:07:46.242 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.243 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.243 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96092 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.246 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.246 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.246 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.246 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96092 (leader epoch 1738) > committed offset 96091 (leader epoch 1738)? 05OCT2024_11:07:46.246 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96092 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.254 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.255 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96092 committed: Success 05OCT2024_11:07:46.255 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.256 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (140 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96092, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.256 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.256 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96093 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.257 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.257 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.257 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.257 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96093 (leader epoch 1738) > committed offset 96092 (leader epoch 1738)? 05OCT2024_11:07:46.257 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96093 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.262 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.262 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96093 committed: Success 05OCT2024_11:07:46.262 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.268 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96093 (leader epoch 1738) > committed offset 96093 (leader epoch 1738)? 05OCT2024_11:07:46.271 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (138 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96093, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.271 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.271 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96094 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.278 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.278 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.278 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.278 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96094 (leader epoch 1738) > committed offset 96093 (leader epoch 1738)? 05OCT2024_11:07:46.278 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96094 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.285 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.285 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96094 committed: Success 05OCT2024_11:07:46.285 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.286 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (141 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96094, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:07:46.286 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.286 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.288 EDDFFB40 INFO CGRPOP 7: [thrd:main]: Group "mygroup" received op OFFSET_COMMIT in state up (join-state init) for my-topic [0] 05OCT2024_11:07:46.288 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: Committing offsets for 1 partition(s) with generation-id -1 in join-state init: auto commit timer 05OCT2024_11:07:46.288 EDDFFB40 INFO OFFSET 7: [thrd:main]: GroupCoordinator/54475: Enqueue OffsetCommitRequest(v8, 1/1 partition(s))): auto commit timer 05OCT2024_11:07:46.288 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96095 (leader epoch 1738) > committed offset 96094 (leader epoch 1738)? 05OCT2024_11:07:46.288 EDDFFB40 INFO OFFSETCMT 7: [thrd:main]: my-topic [0]: committing offset 96095 (leader epoch 1738): auto commit timer 05OCT2024_11:07:46.294 EDDFFB40 INFO COMMIT 7: [thrd:main]: GroupCoordinator/54475: OffsetCommit for 1 partition(s) in join-state init: auto commit timer: returned: Success 05OCT2024_11:07:46.294 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: offset 96095 committed: Success 05OCT2024_11:07:46.294 EDDFFB40 INFO OP 7: [thrd:main]: my-topic [0] received op REPLY:OFFSET_COMMIT (v0) in fetch-state active (opv2) 05OCT2024_11:07:46.299 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96095 (leader epoch 1738) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:46.788 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:46.788 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:46.788 C7D91B40 INFO FETCHERR 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: my-topic [0]: Fetch failed at offset 96095 (leader epoch 1738): _PARTITION_EOF 05OCT2024_11:07:46.790 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:47.291 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:47.291 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:47.301 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:47.793 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:47.793 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:47.802 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:48.296 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:48.296 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:48.302 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:48.802 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:48.802 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:48.802 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:49.304 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:49.304 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:49.312 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:49.806 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:49.806 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:49.811 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:50.309 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:50.309 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:50.314 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:50.811 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:50.811 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:50.814 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:51.314 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:51.314 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:51.314 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:51.817 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:51.817 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:51.825 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:52.319 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:52.319 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:52.326 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:52.822 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:52.822 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:52.827 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:53.328 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:53.328 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:53.329 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:53.831 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:53.831 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:53.840 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:54.338 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:54.338 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:54.341 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:54.841 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:54.841 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:54.842 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:55.345 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:55.345 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:55.345 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:55.847 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:55.847 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:55.847 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:56.353 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:56.353 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:56.358 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:56.856 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:56.856 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:56.859 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:57.359 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:57.359 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:57.864 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:57.864 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:58.368 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:58.368 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:58.373 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:58.870 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:58.870 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:58.874 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:59.373 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:59.373 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:59.376 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:07:59.876 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:07:59.876 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:07:59.877 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:08:00.381 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:08:00.381 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:08:00.381 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:08:00.884 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:08:00.885 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:08:00.890 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? ... 05OCT2024_11:09:01.771 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:09:01.771 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:09:01.771 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:09:02.273 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:09:02.273 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96095 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:09:02.279 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:09:02.496 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (286 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96095, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:09:02.496 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:09:02.496 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96096 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:09:02.503 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96096 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:09:02.999 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:09:02.999 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96096 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:09:02.999 C7D91B40 INFO FETCHERR 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: my-topic [0]: Fetch failed at offset 96096 (leader epoch 1738): _PARTITION_EOF 05OCT2024_11:09:03.001 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96097 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:09:03.502 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:09:03.502 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96096 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:09:03.509 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96097 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? ... 05OCT2024_11:10:17.466 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:10:17.466 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96096 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:10:17.469 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96097 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:10:17.530 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (110 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96096, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:10:17.530 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:10:17.530 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96097 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:10:17.530 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96097 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:10:18.033 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:10:18.033 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96097 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:10:18.033 C7D91B40 INFO FETCHERR 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: my-topic [0]: Fetch failed at offset 96097 (leader epoch 1738): _PARTITION_EOF 05OCT2024_11:10:18.037 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96098 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? ... 05OCT2024_11:11:32.029 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:11:32.029 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96097 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:11:32.036 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96098 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:11:32.302 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (286 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96097, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:11:32.302 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:11:32.302 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96098 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:11:32.311 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96098 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:11:32.804 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:11:32.804 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96098 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:11:32.804 C7D91B40 INFO FETCHERR 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: my-topic [0]: Fetch failed at offset 96098 (leader epoch 1738): _PARTITION_EOF 05OCT2024_11:11:32.809 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96099 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:11:33.306 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:11:33.306 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96098 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:11:33.307 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96099 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? ... 05OCT2024_11:12:16.596 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:12:16.596 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96098 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:12:16.603 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96099 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:12:16.802 C7D91B40 INFO CONSUME 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Enqueue 1 message(s) (118 bytes, 1 ops) on my-topic [0] fetch queue (qlen 0, v2, last_offset 96098, 0 ctrl msgs, 0 aborted msgsets, uncompressed) 05OCT2024_11:12:16.802 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:12:16.802 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96099 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:12:16.806 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96099 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:12:17.304 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch 1/1/1 toppar(s) 05OCT2024_11:12:17.304 C7D91B40 INFO FETCH 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: Fetch topic my-topic [0] at offset 96099 (leader epoch 1738, current leader epoch 1738, v2) 05OCT2024_11:12:17.304 C7D91B40 INFO FETCHERR 7: [thrd:kafka-broker:9092/33223]: kafka-broker:9092/33223: my-topic [0]: Fetch failed at offset 96099 (leader epoch 1738): _PARTITION_EOF 05OCT2024_11:12:17.304 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96099 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:12:17.314 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96100 (leader epoch 0) > committed offset 96095 (leader epoch 1738)? 05OCT2024_11:12:17.325 EDDFFB40 INFO OFFSET 7: [thrd:main]: my-topic [0]: commit: stored offset 96100 (leader epoch 0) > committed offset 96095 (leader epoch 1738)?