You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ce...@apache.org on 2023/04/02 17:09:44 UTC
[kafka] branch trunk updated (145ef2d1e06 -> 970dea60e86)
This is an automated email from the ASF dual-hosted git repository.
cegerton pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 145ef2d1e06 MINOR: fix BrokerMetadataPublisherTest.testExceptionInUpdateCoordinator
add 970dea60e86 KAFKA-14785 (KIP-875): Connect offset read REST API (#13434)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 2 +
.../apache/kafka/connect/mirror/MirrorMaker.java | 7 +-
.../kafka/connect/cli/ConnectDistributed.java | 6 +-
.../kafka/connect/cli/ConnectStandalone.java | 6 +-
.../kafka/connect/runtime/AbstractHerder.java | 15 ++
.../org/apache/kafka/connect/runtime/Herder.java | 8 +
.../org/apache/kafka/connect/runtime/Worker.java | 130 +++++++++-
.../runtime/distributed/DistributedHerder.java | 14 +
.../connect/runtime/rest/HerderRequestHandler.java | 96 +++----
.../runtime/rest/entities/ConnectorOffset.java | 79 ++++++
.../runtime/rest/entities/ConnectorOffsets.java | 76 ++++++
.../runtime/rest/resources/ConnectorsResource.java | 43 ++--
.../runtime/standalone/StandaloneHerder.java | 9 +-
.../storage/ConnectorOffsetBackingStore.java | 10 +
.../connect/storage/FileOffsetBackingStore.java | 16 +-
.../connect/storage/KafkaConfigBackingStore.java | 6 +-
.../connect/storage/KafkaOffsetBackingStore.java | 43 ++--
.../connect/storage/MemoryOffsetBackingStore.java | 6 +-
.../kafka/connect/storage/OffsetBackingStore.java | 8 +
.../apache/kafka/connect/storage/OffsetUtils.java | 70 +++++
.../apache/kafka/connect/util/ConnectUtils.java | 9 +
.../org/apache/kafka/connect/util/SinkUtils.java | 28 ++
.../integration/MonitorableSourceConnector.java | 14 +-
.../integration/OffsetsApiIntegrationTest.java | 281 +++++++++++++++++++++
.../kafka/connect/runtime/AbstractHerderTest.java | 60 ++++-
.../apache/kafka/connect/runtime/WorkerTest.java | 197 +++++++++++++--
.../runtime/distributed/DistributedHerderTest.java | 35 +++
.../rest/resources/ConnectorsResourceTest.java | 44 +++-
.../storage/FileOffsetBackingStoreTest.java | 105 +++++++-
.../storage/KafkaOffsetBackingStoreTest.java | 90 ++++++-
.../kafka/connect/storage/OffsetUtilsTest.java | 137 ++++++++++
.../apache/kafka/connect/util/SinkUtilsTest.java | 49 ++++
.../util/clusters/EmbeddedConnectCluster.java | 22 ++
33 files changed, 1564 insertions(+), 157 deletions(-)
create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorOffset.java
create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorOffsets.java
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/storage/OffsetUtilsTest.java
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/util/SinkUtilsTest.java