KAFKA-10000: Per-connector offsets topics (#11781)
Implements support for per-connector offsets topics as described in KIP-618. Reviewers: Luke Chen <showuon@gmail.com>, Tom Bentley <tbentley@redhat.com>
显示
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java 6 个添加, 4 个删除...pache/kafka/connect/runtime/AbstractWorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java 15 个添加, 11 个删除...he/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java 284 个添加, 20 个删除...rc/main/java/org/apache/kafka/connect/runtime/Worker.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java 5 个添加, 1 个删除...ava/org/apache/kafka/connect/runtime/WorkerConnector.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java 2 个添加, 2 个删除...va/org/apache/kafka/connect/runtime/WorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java 2 个添加, 2 个删除...ain/java/org/apache/kafka/connect/runtime/WorkerTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java 281 个添加, 11 个删除...he/kafka/connect/storage/ConnectorOffsetBackingStore.java
- connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java 1 个添加, 3 个删除...apache/kafka/connect/storage/KafkaConfigBackingStore.java
- connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java 145 个添加, 17 个删除...apache/kafka/connect/storage/KafkaOffsetBackingStore.java
- connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java 99 个添加, 25 个删除...ain/java/org/apache/kafka/connect/util/KafkaBasedLog.java
- connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java 18 个添加, 29 个删除...c/main/java/org/apache/kafka/connect/util/TopicAdmin.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java 4 个添加, 2 个删除...g/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTaskTest.java 4 个添加, 3 个删除...afka/connect/runtime/ExactlyOnceWorkerSourceTaskTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConnectorTest.java 18 个添加, 0 个删除...org/apache/kafka/connect/runtime/WorkerConnectorTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java 21 个添加, 48 个删除...rg/apache/kafka/connect/runtime/WorkerSourceTaskTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java 469 个添加, 3 个删除...est/java/org/apache/kafka/connect/runtime/WorkerTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java 85 个添加, 0 个删除...he/kafka/connect/storage/KafkaOffsetBackingStoreTest.java
加载中
想要评论请 注册 或 登录