kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rha...@apache.org
Subject [kafka] branch trunk updated (16edc54 -> 791d0d6)
Date Wed, 02 Oct 2019 22:07:34 GMT
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


Mime
View raw message