You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vi...@apache.org on 2023/05/24 09:05:10 UTC

[kafka] branch trunk updated (1c5cf4e170a -> 5b3b385881d)

This is an automated email from the ASF dual-hosted git repository.

viktor pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from 1c5cf4e170a MINOR: Fix ListOffsetsRequestTest.testResponseIncludesLeaderEpoch (#13747)
     add 5b3b385881d KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException (#11565)

No new revisions were added by this update.

Summary of changes:
 .../connect/storage/KafkaConfigBackingStore.java   | 31 ++++-----
 .../connect/storage/KafkaOffsetBackingStore.java   | 42 +++++--------
 .../connect/storage/KafkaStatusBackingStore.java   | 34 ++++------
 .../storage/KafkaTopicBasedBackingStore.java       | 73 ++++++++++++++++++++++
 .../org/apache/kafka/connect/util/TopicAdmin.java  | 51 +++++++++++++++
 .../storage/KafkaConfigBackingStoreTest.java       |  4 +-
 .../storage/KafkaOffsetBackingStoreTest.java       |  4 +-
 .../storage/KafkaStatusBackingStoreTest.java       | 33 +++++-----
 .../apache/kafka/connect/util/TopicAdminTest.java  | 35 +++++++++++
 9 files changed, 217 insertions(+), 90 deletions(-)
 create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaTopicBasedBackingStore.java