This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 16edc54 KAFKA-5609: Connect log4j should also log to a file by
default (KIP-521) (#7430)
add 791d0d6 KAFKA-8804: Secure internal Connect REST endpoints (#7310)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 6 +
checkstyle/suppressions.xml | 2 +-
.../connect/runtime/ConnectMetricsRegistry.java | 2 +
.../org/apache/kafka/connect/runtime/Herder.java | 5 +-
.../apache/kafka/connect/runtime/SessionKey.java | 73 ++++
.../runtime/distributed/ClusterConfigState.java | 18 +
.../distributed/ConnectProtocolCompatibility.java | 64 ++-
.../runtime/distributed/DistributedConfig.java | 437 +++++++++++++--------
.../runtime/distributed/DistributedHerder.java | 202 +++++++++-
.../IncrementalCooperativeAssignor.java | 19 +-
.../IncrementalCooperativeConnectProtocol.java | 49 ++-
.../runtime/distributed/WorkerCoordinator.java | 6 +-
.../runtime/rest/InternalRequestSignature.java | 148 +++++++
.../kafka/connect/runtime/rest/RestClient.java | 43 +-
.../runtime/rest/resources/ConnectorsResource.java | 10 +-
.../runtime/standalone/StandaloneHerder.java | 9 +-
.../kafka/connect/storage/ConfigBackingStore.java | 9 +
.../connect/storage/KafkaConfigBackingStore.java | 71 ++++
.../connect/storage/MemoryConfigBackingStore.java | 7 +
.../SessionedProtocolIntegrationTest.java | 168 ++++++++
.../kafka/connect/runtime/AbstractHerderTest.java | 4 +-
.../kafka/connect/runtime/WorkerTestUtils.java | 1 +
.../ConnectProtocolCompatibilityTest.java | 27 +-
.../runtime/distributed/DistributedConfigTest.java | 108 +++++
.../runtime/distributed/DistributedHerderTest.java | 140 ++++++-
.../IncrementalCooperativeAssignorTest.java | 72 ++--
.../WorkerCoordinatorIncrementalTest.java | 13 +-
.../runtime/distributed/WorkerCoordinatorTest.java | 3 +
.../runtime/rest/InternalRequestSignatureTest.java | 151 +++++++
.../kafka/connect/runtime/rest/RestServerTest.java | 2 +-
.../rest/resources/ConnectorsResourceTest.java | 71 +++-
.../runtime/standalone/StandaloneHerderTest.java | 6 +-
.../storage/KafkaConfigBackingStoreTest.java | 2 +-
.../storage/KafkaOffsetBackingStoreTest.java | 2 +-
.../util/clusters/EmbeddedConnectCluster.java | 22 ++
.../tests/connect/connect_distributed_test.py | 23 +-
.../templates/connect-distributed.properties | 2 +-
37 files changed, 1730 insertions(+), 267 deletions(-)
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignatureTest.java
