You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2020/01/30 05:55:08 UTC
[kafka] branch trunk updated (8494fdb -> 7746301)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8494fdb KAFKA-9040; Add --all option to config command (#7607)
add 7746301 KAFKA-9422: Track the set of topics a connector is using (KIP-558) (#8017)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/AbstractHerder.java | 21 +++
.../org/apache/kafka/connect/runtime/Herder.java | 25 ++-
.../apache/kafka/connect/runtime/TopicStatus.java | 110 ++++++++++++
.../org/apache/kafka/connect/runtime/Worker.java | 4 +-
.../apache/kafka/connect/runtime/WorkerConfig.java | 16 +-
.../kafka/connect/runtime/WorkerSinkTask.java | 10 +-
.../kafka/connect/runtime/WorkerSourceTask.java | 10 +-
.../apache/kafka/connect/runtime/WorkerTask.java | 23 ++-
.../runtime/rest/entities/ActiveTopicsInfo.java | 27 +--
.../runtime/rest/resources/ConnectorsResource.java | 34 ++++
.../connect/storage/KafkaStatusBackingStore.java | 187 +++++++++++++++++++--
.../connect/storage/MemoryStatusBackingStore.java | 35 ++++
.../kafka/connect/storage/StatusBackingStore.java | 29 ++++
.../connect/runtime/ErrorHandlingTaskTest.java | 33 +++-
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 47 +++++-
.../runtime/WorkerSinkTaskThreadedTest.java | 36 +++-
.../connect/runtime/WorkerSourceTaskTest.java | 28 ++-
.../kafka/connect/runtime/WorkerTaskTest.java | 25 ++-
.../apache/kafka/connect/runtime/WorkerTest.java | 27 ++-
.../storage/KafkaStatusBackingStoreFormatTest.java | 75 +++++++++
20 files changed, 751 insertions(+), 51 deletions(-)
create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java
copy tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyTaskRequest.java => connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ActiveTopicsInfo.java (66%)
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.java