Re: [PR] KAFKA-16556: SubscriptionState should not prematurely reset 'pending' partitions [kafka]

2024-04-16 Thread via GitHub
lucasbru merged PR #15724: URL: https://github.com/apache/kafka/pull/15724 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] KAFKA-16556: SubscriptionState should not prematurely reset 'pending' partitions [kafka]

2024-04-15 Thread via GitHub
kirktrue commented on PR #15724: URL: https://github.com/apache/kafka/pull/15724#issuecomment-2058081763 @lucasbru—please kindly take a look at this issue that's occasionally causing consumers to ignore committed offsets. The result is the consumer resets the partition's position back to

[PR] KAFKA-16556: SubscriptionState should not prematurely reset 'pending' partitions [kafka]

2024-04-15 Thread via GitHub
kirktrue opened a new pull request, #15724: URL: https://github.com/apache/kafka/pull/15724 Partitions that are marked as `pendingOnAssignedCallback` should not be reset in `resetInitializingPositions()`. Pending partitions are omitted from the set returned by `initializingPartitions()`.