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 4550550c7cb MINOR: Cleanup TestPlugins and normalize TestPlugin enum
(#13333)
add 27220d146c5 KAFKA-10816: Add health check endpoint for Kafka Connect
(#16477)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/common/utils/Time.java | 4 +-
.../kafka/connect/cli/AbstractConnectCli.java | 23 ++--
.../kafka/connect/cli/ConnectDistributed.java | 5 +-
.../kafka/connect/cli/ConnectStandalone.java | 9 +-
.../kafka/connect/runtime/AbstractHerder.java | 10 +-
.../org/apache/kafka/connect/runtime/Connect.java | 14 +--
.../org/apache/kafka/connect/runtime/Herder.java | 13 +-
.../runtime/distributed/DistributedHerder.java | 24 ++--
.../connect/runtime/rest/HerderRequestHandler.java | 13 +-
.../connect/runtime/rest/RestRequestTimeout.java | 19 +++
.../kafka/connect/runtime/rest/RestServer.java | 21 +++-
.../runtime/rest/entities/WorkerStatus.java | 99 +++++++++++++++
.../runtime/rest/resources/RootResource.java | 58 ++++++++-
.../runtime/standalone/HealthCheckThread.java | 136 +++++++++++++++++++++
.../runtime/standalone/StandaloneHerder.java | 17 ++-
.../java/org/apache/kafka/connect/util/Stage.java | 16 +++
.../connect/integration/BlockingConnectorTest.java | 7 +-
.../integration/ConnectWorkerIntegrationTest.java | 50 +++++++-
.../integration/InternalTopicsIntegrationTest.java | 37 ++++--
.../SourceConnectorsIntegrationTest.java | 2 +-
.../StandaloneWorkerIntegrationTest.java | 133 +++++++++++++++++++-
.../resources/ConnectorPluginsResourceTest.java | 8 +-
.../rest/resources/ConnectorsResourceTest.java | 8 +-
.../resources/InternalConnectResourceTest.java | 7 +-
.../runtime/rest/resources/RootResourceTest.java | 115 ++++++++++++++++-
.../connect/util/clusters/ConnectAssertions.java | 2 +-
.../connect/util/clusters/EmbeddedConnect.java | 60 +++++----
.../util/clusters/EmbeddedConnectCluster.java | 8 +-
.../util/clusters/EmbeddedConnectStandalone.java | 51 +++++++-
.../util/clusters/EmbeddedKafkaCluster.java | 54 +++++---
.../kafka/connect/util/clusters/WorkerHandle.java | 44 +++----
31 files changed, 911 insertions(+), 156 deletions(-)
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/WorkerStatus.java
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/HealthCheckThread.java
