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