"2022-12-14 11:18:32 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:32 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:31 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:31 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:31 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:31 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:31 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:31 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:31 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:31 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:31 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" ========================================================================================================= "2022-12-14 11:18:31 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:31 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-74])" "2022-12-14 11:18:31 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-74]\n\tCurrent owned partitions: [partition-74]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:31 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:29 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=641, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:29 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=641, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:29 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:29 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-38])" "2022-12-14 11:18:29 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-38]\n\tCurrent owned partitions: [partition-38]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:29 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=641, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:29 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=641, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=641, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:28 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-59])" "2022-12-14 11:18:28 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-59]\n\tCurrent owned partitions: [partition-59]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:28 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=641, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=641, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:28 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-2, partition-93])" "2022-12-14 11:18:28 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-2, partition-93]\n\tCurrent owned partitions: [partition-2, partition-93]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:28 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=641, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=641, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:28 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-82])" "2022-12-14 11:18:28 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-82]\n\tCurrent owned partitions: [partition-82]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:28 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=641, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=641, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:28 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=641, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:25 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:24 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:24 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" ============================================================================================================= "2022-12-14 11:18:24 1 --- [consumer-3] x.y.z.MyRebalanceHandler1 : New partition assignment: partition-59, seek to min common offset: 85120524" "2022-12-14 11:18:24 1 --- [consumer-3] x.y.z.MyRebalanceHandler2 : Partitions [partition-59] assigned successfully" "2022-12-14 11:18:24 1 --- [consumer-3] x.y.z.MyRebalanceHandler1 : Partitions assigned: [partition-59]" "2022-12-14 11:18:24 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: partition-59" "2022-12-14 11:18:24 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-59])" "2022-12-14 11:18:24 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: need to revoke partitions [partition-26, partition-74] as indicated by the current assignment and re-join" "2022-12-14 11:18:24 1 --- [consumer-3] x.y.z.MyRebalanceHandler2 : Partitions [partition-26, partition-74] revoked successfully" "2022-12-14 11:18:24 1 --- [consumer-3] x.y.z.MyRebalanceHandler1 : Finished removing partition data" "2022-12-14 11:18:24 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:24 1 --- [consumer-4] x.y.z.MyRebalanceHandler1 : New partition assignment: partition-74, seek to min common offset: 107317730" "2022-12-14 11:18:24 1 --- [consumer-4] x.y.z.MyRebalanceHandler2 : Partitions [partition-74] assigned successfully" "2022-12-14 11:18:24 1 --- [consumer-4] x.y.z.MyRebalanceHandler1 : Partitions assigned: [partition-74]" "2022-12-14 11:18:24 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: partition-74" "2022-12-14 11:18:24 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-74])" "2022-12-14 11:18:24 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: need to revoke partitions [partition-57] as indicated by the current assignment and re-join" "2022-12-14 11:18:24 1 --- [consumer-4] x.y.z.MyRebalanceHandler2 : Partitions [partition-57] revoked successfully" "2022-12-14 11:18:24 1 --- [consumer-4] x.y.z.MyRebalanceHandler1 : Finished removing partition data" "2022-12-14 11:18:23 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:23 1 --- [consumer-1] x.y.z.MyRebalanceHandler1 : New partition assignment: partition-21, seek to min common offset: 179564205" "2022-12-14 11:18:23 1 --- [consumer-1] x.y.z.MyRebalanceHandler2 : Partitions [partition-21] assigned successfully" "2022-12-14 11:18:23 1 --- [consumer-1] x.y.z.MyRebalanceHandler1 : Partitions assigned: [partition-21]" "2022-12-14 11:18:23 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: partition-21" "2022-12-14 11:18:23 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-21])" "2022-12-14 11:18:23 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: need to revoke partitions [partition-10, partition-58] as indicated by the current assignment and re-join" "2022-12-14 11:18:23 1 --- [consumer-1] x.y.z.MyRebalanceHandler2 : Partitions [partition-10, partition-58] revoked successfully" "2022-12-14 11:18:23 1 --- [consumer-1] x.y.z.MyRebalanceHandler1 : Finished removing partition data" "2022-12-14 11:18:23 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:23 1 --- [consumer-5] x.y.z.MyRebalanceHandler1 : New partition assignment: partition-82, seek to min common offset: 83690973" "2022-12-14 11:18:23 1 --- [consumer-5] x.y.z.MyRebalanceHandler2 : Partitions [partition-82] assigned successfully" "2022-12-14 11:18:23 1 --- [consumer-5] x.y.z.MyRebalanceHandler1 : Partitions assigned: [partition-82]" "2022-12-14 11:18:23 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: partition-82" "2022-12-14 11:18:23 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-82])" "2022-12-14 11:18:23 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: need to revoke partitions [partition-65] as indicated by the current assignment and re-join" "2022-12-14 11:18:23 1 --- [consumer-5] x.y.z.MyRebalanceHandler2 : Partitions [partition-65] revoked successfully" "2022-12-14 11:18:23 1 --- [consumer-5] x.y.z.MyRebalanceHandler1 : Finished removing partition data" "2022-12-14 11:18:22 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:22 1 --- [consumer-2] x.y.z.MyRebalanceHandler1 : New partition assignment: partition-38, seek to min common offset: 78179139" "2022-12-14 11:18:22 1 --- [consumer-2] x.y.z.MyRebalanceHandler2 : Partitions [partition-38] assigned successfully" "2022-12-14 11:18:22 1 --- [consumer-2] x.y.z.MyRebalanceHandler1 : Partitions assigned: [partition-38]" "2022-12-14 11:18:22 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: partition-38" "2022-12-14 11:18:22 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-38])" "2022-12-14 11:18:22 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: need to revoke partitions [partition-34] as indicated by the current assignment and re-join" "2022-12-14 11:18:22 1 --- [consumer-2] x.y.z.MyRebalanceHandler2 : Partitions [partition-34] revoked successfully" "2022-12-14 11:18:22 1 --- [consumer-2] x.y.z.MyRebalanceHandler1 : Finished removing partition data" "2022-12-14 11:18:22 1 --- [consumer-3] x.y.z.MyRebalanceHandler1 : Partitions revoked: [partition-26, partition-74]" "2022-12-14 11:18:22 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Revoke previously assigned partitions partition-26, partition-74" "2022-12-14 11:18:22 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-59]\n\tCurrent owned partitions: [partition-26, partition-74]\n\tAdded partitions (assigned - owned): [partition-59]\n\tRevoked partitions (owned - assigned): [partition-26, partition-74]" "2022-12-14 11:18:22 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=640, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:22 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=640, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:22 1 --- [consumer-4] x.y.z.MyRebalanceHandler1 : Partitions revoked: [partition-57]" "2022-12-14 11:18:22 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Revoke previously assigned partitions partition-57" "2022-12-14 11:18:22 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-74]\n\tCurrent owned partitions: [partition-57]\n\tAdded partitions (assigned - owned): [partition-74]\n\tRevoked partitions (owned - assigned): [partition-57]" "2022-12-14 11:18:21 1 --- [consumer-1] x.y.z.MyRebalanceHandler1 : Partitions revoked: [partition-10, partition-58]" "2022-12-14 11:18:21 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Revoke previously assigned partitions partition-10, partition-58" "2022-12-14 11:18:21 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-21]\n\tCurrent owned partitions: [partition-10, partition-58]\n\tAdded partitions (assigned - owned): [partition-21]\n\tRevoked partitions (owned - assigned): [partition-10, partition-58]" "2022-12-14 11:18:21 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=640, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=640, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=640, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=640, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:21 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-2, partition-93])" "2022-12-14 11:18:21 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-2, partition-93]\n\tCurrent owned partitions: [partition-2, partition-93]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:21 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=640, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-5] x.y.z.MyRebalanceHandler1 : Partitions revoked: [partition-65]" "2022-12-14 11:18:21 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Revoke previously assigned partitions partition-65" "2022-12-14 11:18:21 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-82]\n\tCurrent owned partitions: [partition-65]\n\tAdded partitions (assigned - owned): [partition-82]\n\tRevoked partitions (owned - assigned): [partition-65]" "2022-12-14 11:18:21 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=640, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=640, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=640, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-2] x.y.z.MyRebalanceHandler1 : Partitions revoked: [partition-34]" "2022-12-14 11:18:21 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Revoke previously assigned partitions partition-34" "2022-12-14 11:18:21 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-38]\n\tCurrent owned partitions: [partition-34]\n\tAdded partitions (assigned - owned): [partition-38]\n\tRevoked partitions (owned - assigned): [partition-34]" "2022-12-14 11:18:21 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=640, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=640, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:21 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:19 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:18 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:18 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:18 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" "2022-12-14 11:18:18 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" ============================================================================== "2022-12-14 11:18:17 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:17 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" "2022-12-14 11:18:17 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=639, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:17 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=639, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:17 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=639, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:17 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=639, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:17 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:17 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" "2022-12-14 11:18:17 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:17 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" "2022-12-14 11:18:17 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=639, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:17 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:17 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-2, partition-93])" "2022-12-14 11:18:17 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=639, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:17 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-2, partition-93]\n\tCurrent owned partitions: [partition-2, partition-93]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:16 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=639, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:16 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=639, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:16 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=639, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:16 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=639, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:16 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=639, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:16 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=639, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:15 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:15 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:15 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:15 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:14 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:14 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:14 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:14 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:18:12 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" =============================================================================== "2022-12-14 11:18:12 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" "2022-12-14 11:18:12 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=638, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=638, memberId='partition-1-my-client-id-my-group-id-f6d724ed-e94f-4271-8f05-c9b3f5714bc8', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:18:11 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException)" "2022-12-14 11:18:11 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=638, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-5] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-5-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=638, memberId='partition-5-my-client-id-my-group-id-cf0a5380-6ef6-4915-a8fb-de657d92367f', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:11 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-34])" "2022-12-14 11:18:11 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-34]\n\tCurrent owned partitions: [partition-34]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:11 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:11 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-2, partition-93])" "2022-12-14 11:18:11 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-2, partition-93]\n\tCurrent owned partitions: [partition-2, partition-93]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:11 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:11 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-26, partition-74])" "2022-12-14 11:18:11 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-26, partition-74]\n\tCurrent owned partitions: [partition-26, partition-74]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:11 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=638, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=638, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-0] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-0-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=638, memberId='partition-0-my-client-id-my-group-id-6494d956-6860-4ebf-a16e-5d27109252bc', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=638, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Adding newly assigned partitions: " "2022-12-14 11:18:11 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Notifying assignor about the new Assignment(partitions=[partition-57])" "2022-12-14 11:18:11 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Updating assignment with\n\tAssigned partitions: [partition-57]\n\tCurrent owned partitions: [partition-57]\n\tAdded partitions (assigned - owned): []\n\tRevoked partitions (owned - assigned): []" "2022-12-14 11:18:11 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully synced group in generation Generation{generationId=638, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-4] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-4-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=638, memberId='partition-4-my-client-id-my-group-id-ae2af665-edc9-4a8e-b658-98372d142477', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=638, memberId='partition-2-my-client-id-my-group-id-5b42553a-8cf8-46e9-bb78-18d3ee67672f', protocol='cooperative-sticky'}" "2022-12-14 11:18:11 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Successfully joined group with generation Generation{generationId=638, memberId='partition-3-my-client-id-my-group-id-c31afd19-3f22-43cb-ad07-9088aa98d3af', protocol='cooperative-sticky'}" "2022-12-14 11:17:57 1 --- [consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:17:57 1 --- [consumer-3] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" "2022-12-14 11:17:56 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-1-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:17:56 1 --- [my-group-id] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-3-my-client-id-my-group-id, groupId=my-group-id] Request joining group due to: group is already rebalancing" "2022-12-14 11:17:56 1 --- [consumer-2] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=partition-2-my-client-id-my-group-id, groupId=my-group-id] (Re-)joining group" ===================================================================