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 453cf9c9876 KAFKA-17434: Do not test impossible scenarios in
upgrade_test.py (#17024)
add 8db80d1f070 KAFKA-17064: New consumer assign should update assignment
in background thread (#16673)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/AsyncKafkaConsumer.java | 10 ++---
.../clients/consumer/internals/ConsumerUtils.java | 4 ++
.../events/ApplicationEventProcessor.java | 29 +++++++------
.../internals/events/AssignmentChangeEvent.java | 24 +++++------
.../NewTopicsMetadataUpdateRequestEvent.java | 24 -----------
.../consumer/internals/AsyncKafkaConsumerTest.java | 40 ++++++++++++++++--
.../events/ApplicationEventProcessorTest.java | 49 +++++++++++++++++++---
7 files changed, 115 insertions(+), 65 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/NewTopicsMetadataUpdateRequestEvent.java
