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 2021/02/09 17:11:21 UTC

[kafka] branch trunk updated (e7e4252 -> 982ea2f)

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 e7e4252  JUnit extensions for integration tests (#9986)
     add 982ea2f  KAFKA-10021: Changed Kafka backing stores to use shared admin client to get end offsets and create topics (#9780)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/connect/mirror/MirrorMaker.java   |  17 +-
 .../kafka/connect/cli/ConnectDistributed.java      |  18 +-
 .../runtime/distributed/DistributedHerder.java     |  37 ++-
 .../connect/storage/KafkaConfigBackingStore.java   |  33 ++-
 .../connect/storage/KafkaOffsetBackingStore.java   |  37 ++-
 .../connect/storage/KafkaStatusBackingStore.java   |  33 ++-
 .../apache/kafka/connect/util/KafkaBasedLog.java   |  73 +++++-
 .../kafka/connect/util/SharedTopicAdmin.java       | 145 +++++++++++
 .../org/apache/kafka/connect/util/TopicAdmin.java  |  67 +++++
 .../runtime/distributed/DistributedHerderTest.java |  13 +-
 .../storage/KafkaConfigBackingStoreTest.java       |   6 +-
 .../storage/KafkaOffsetBackingStoreTest.java       |   6 +-
 .../kafka/connect/util/SharedTopicAdminTest.java   | 112 +++++++++
 .../apache/kafka/connect/util/TopicAdminTest.java  | 275 ++++++++++++++++++++-
 14 files changed, 808 insertions(+), 64 deletions(-)
 create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/util/SharedTopicAdmin.java
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/util/SharedTopicAdminTest.java