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/05/26 16:08:32 UTC
[kafka] branch trunk updated (a27c98ca61d -> 7ff2dbb1078)

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 a27c98ca61d MINOR: remove unused variable from QuorumMetaLogListener#handleCommit method (#13611)
     add 7ff2dbb1078 KAFKA-14368: Connect offset write REST API (#13465)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   1 +
 .../apache/kafka/connect/sink/SinkConnector.java   |  32 ++
 .../kafka/connect/source/SourceConnector.java      |  31 ++
 .../org/apache/kafka/connect/runtime/Herder.java   |   9 +
 .../org/apache/kafka/connect/runtime/Worker.java   | 341 ++++++++++++--
 .../runtime/distributed/DistributedHerder.java     | 209 ++++++---
 .../connect/runtime/rest/HerderRequestHandler.java |  25 +-
 .../runtime/rest/entities/ConnectorOffsets.java    |  10 +
 .../connect/runtime/rest/entities/Message.java     |  45 +-
 .../runtime/rest/errors/BadRequestException.java   |   3 +
 .../runtime/rest/resources/ConnectorsResource.java |  19 +
 .../runtime/standalone/StandaloneHerder.java       |  21 +-
 .../connect/storage/KafkaOffsetBackingStore.java   |   4 +-
 .../org/apache/kafka/connect/util/SinkUtils.java   |  83 ++++
 .../integration/MonitorableSinkConnector.java      |   8 +
 .../integration/MonitorableSourceConnector.java    |   8 +
 .../integration/OffsetsApiIntegrationTest.java     | 497 ++++++++++++++++++---
 .../apache/kafka/connect/runtime/WorkerTest.java   | 441 ++++++++++++++++--
 .../runtime/distributed/DistributedHerderTest.java | 336 +++++++++++++-
 .../rest/entities/ConnectorOffsetsTest.java        |  52 +++
 .../rest/resources/ConnectorsResourceTest.java     |  53 +++
 .../runtime/standalone/StandaloneHerderTest.java   |  66 +++
 .../apache/kafka/connect/util/SinkUtilsTest.java   | 142 ++++++
 .../util/clusters/EmbeddedConnectCluster.java      | 101 +++--
 24 files changed, 2261 insertions(+), 276 deletions(-)
 copy trogdor/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java => connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/Message.java (59%)
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorOffsetsTest.java