This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 1eecd02ce84 MINOR: Deflake EligibleLeaderReplicasIntegrationTest
(#18923)
add 709bfc506a9 KAFKA-18641: AsyncKafkaConsumer could lose records with
auto offset commit (#18737)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../internals/AbstractMembershipManager.java | 25 +++-
.../consumer/internals/AsyncKafkaConsumer.java | 14 +-
.../consumer/internals/CommitRequestManager.java | 68 +++++----
.../internals/ConsumerMembershipManager.java | 17 ++-
.../consumer/internals/RequestManagers.java | 3 +-
.../consumer/internals/ShareMembershipManager.java | 3 +-
.../events/ApplicationEventProcessor.java | 25 +++-
.../consumer/internals/events/CommitEvent.java | 16 +++
.../consumer/internals/events/PollEvent.java | 24 ++++
.../consumer/internals/AsyncKafkaConsumerTest.java | 45 +++++-
.../internals/CommitRequestManagerTest.java | 159 +++++++--------------
.../internals/ConsumerMembershipManagerTest.java | 117 +++++++--------
.../events/ApplicationEventProcessorTest.java | 82 +++++++----
14 files changed, 357 insertions(+), 243 deletions(-)
