KAFKA-14089: Only check for committed seqnos after disabling exactly-once...
KAFKA-14089: Only check for committed seqnos after disabling exactly-once support in Connect integration test (#12429) Reviewers: Mickael Maison <mickael.maison@gmail.com> , Tom Bentley <tbentley@redhat.com>
显示
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java 3 个添加, 0 个删除...he/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java 13 个添加, 0 个删除...rc/main/java/org/apache/kafka/connect/runtime/Worker.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExactlyOnceSourceIntegrationTest.java 138 个添加, 54 个删除...connect/integration/ExactlyOnceSourceIntegrationTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java 1 个添加, 1 个删除...kafka/connect/integration/MonitorableSourceConnector.java
加载中
想要评论请 注册 或 登录