This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 6b41993 KAFKA-9662: Wait for consumer offset reset in throttle test
to avoid losing early messages (#8227)
add ca90a84 KAFKA-9668: Iterating over KafkaStreams.getAllMetadata()
results in ConcurrentModificationException (#8233)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/StreamsMetadataState.java | 21 ++++---
.../kafka/streams/state/StreamsMetadata.java | 8 +--
.../internals/StreamsMetadataStateTest.java | 26 +++++++++
.../kafka/streams/state/StreamsMetadataTest.java | 64 ++++++++++++++++++++++
4 files changed, 106 insertions(+), 13 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/StreamsMetadataTest.java
