This is an automated email from the ASF dual-hosted git repository.
kkarantasis pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 1b7ab8e KAFKA-12863: Configure controller snapshot generation (#10812)
add 527ba11 KAFKA-4793: Connect API to restart connector and tasks
(KIP-745) (#10822)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../kafka/connect/runtime/AbstractHerder.java | 58 +++
.../kafka/connect/runtime/AbstractStatus.java | 1 +
.../connect/runtime/ConnectMetricsRegistry.java | 5 +
.../kafka/connect/runtime/ConnectorStatus.java | 5 +
.../org/apache/kafka/connect/runtime/Herder.java | 7 +
.../apache/kafka/connect/runtime/RestartPlan.java | 149 +++++++
.../kafka/connect/runtime/RestartRequest.java | 144 +++++++
.../apache/kafka/connect/runtime/StateTracker.java | 19 +-
.../apache/kafka/connect/runtime/TaskStatus.java | 6 +
.../kafka/connect/runtime/WorkerConnector.java | 6 +
.../apache/kafka/connect/runtime/WorkerTask.java | 6 +
.../runtime/distributed/DistributedHerder.java | 158 +++++++-
.../runtime/rest/resources/ConnectorsResource.java | 44 ++-
.../runtime/standalone/StandaloneHerder.java | 71 +++-
.../kafka/connect/storage/ConfigBackingStore.java | 13 +
.../connect/storage/KafkaConfigBackingStore.java | 69 ++++
.../connect/storage/MemoryConfigBackingStore.java | 6 +
.../kafka/connect/integration/ConnectorHandle.java | 50 ++-
.../ConnectorRestartApiIntegrationTest.java | 435 +++++++++++++++++++++
.../integration/MonitorableSourceConnector.java | 6 +
.../connect/integration/StartAndStopCounter.java | 4 +
.../kafka/connect/integration/StartsAndStops.java} | 22 +-
.../kafka/connect/integration/TaskHandle.java | 13 +
.../kafka/connect/runtime/AbstractHerderTest.java | 103 +++++
.../kafka/connect/runtime/RestartPlanTest.java | 98 +++++
.../kafka/connect/runtime/RestartRequestTest.java | 111 ++++++
.../kafka/connect/runtime/StateTrackerTest.java | 5 +
.../runtime/distributed/DistributedHerderTest.java | 342 +++++++++++++++-
.../rest/resources/ConnectorsResourceTest.java | 84 +++-
.../runtime/standalone/StandaloneHerderTest.java | 237 ++++++++++-
.../storage/KafkaConfigBackingStoreTest.java | 133 +++++++
.../util/clusters/EmbeddedConnectCluster.java | 61 +++
.../clusters/EmbeddedConnectClusterAssertions.java | 85 ++++
tests/kafkatest/services/connect.py | 3 +
.../tests/connect/connect_distributed_test.py | 44 +++
36 files changed, 2555 insertions(+), 50 deletions(-)
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/RestartPlan.java
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/RestartRequest.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorRestartApiIntegrationTest.java
copy
connect/runtime/src/{main/java/org/apache/kafka/connect/util/FutureCallback.java
=> test/java/org/apache/kafka/connect/integration/StartsAndStops.java} (70%)
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartPlanTest.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartRequestTest.java
