KSTORAGE-885: add lagging and realtime consumer to retention ms/bytes system test (#2465)
This PR improves the validation of the retention stress test by starting a lagging consumer at the end of the test and which reads from the beginning of the topic. Initial timestamps for the lagging consumer are validated in the same way as they are periodically validated while writing.
显示
- tests/kafkatest/services/kafka/kafka.py 11 个添加, 0 个删除tests/kafkatest/services/kafka/kafka.py
- tests/kafkatest/tests/core/retention_stress_test.py 69 个添加, 19 个删除tests/kafkatest/tests/core/retention_stress_test.py
- tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java 5 个添加, 1 个删除.../main/java/org/apache/kafka/tools/VerifiableConsumer.java
加载中
想要评论请 注册 或 登录