KAFKA-10191 fix flaky StreamsOptimizedTest (#8913)
Call KafkaStreams#cleanUp to reset local state before starting application up the second run. Reviewers: A. Sophie Blee-Goldman <sophie@confluent.io>, Boyang Chen <boyang@confluent.io>, John Roesler <john@confluent.io>
显示
- core/src/main/scala/kafka/tools/StreamsResetter.java 0 个添加, 1 个删除core/src/main/scala/kafka/tools/StreamsResetter.java
- streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java 1 个添加, 0 个删除.../org/apache/kafka/streams/tests/StreamsOptimizedTest.java
- tests/kafkatest/services/streams.py 44 个添加, 1 个删除tests/kafkatest/services/streams.py
- tests/kafkatest/tests/streams/streams_optimized_test.py 9 个添加, 0 个删除tests/kafkatest/tests/streams/streams_optimized_test.py
想要评论请 注册 或 登录