You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by kk...@apache.org on 2020/06/11 08:29:51 UTC
[kafka] branch trunk updated (5f7b07b -> 7f4fc76)

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 5f7b07b  MINOR: reduce sizeInBytes for percentiles metrics (#8835)
     add 7f4fc76  KAFKA-9374: Make connector interactions asynchronous (#8069)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/runtime/AbstractHerder.java      |  22 +-
 .../runtime/CloseableConnectorContext.java}        |  18 +-
 .../org/apache/kafka/connect/runtime/Herder.java   |   8 +-
 .../connect/runtime/HerderConnectorContext.java    |  28 +-
 .../org/apache/kafka/connect/runtime/Worker.java   | 171 ++++--
 .../kafka/connect/runtime/WorkerConnector.java     | 223 +++++++-
 .../runtime/distributed/DistributedHerder.java     | 314 +++++++----
 .../rest/resources/ConnectorPluginsResource.java   |  18 +-
 .../runtime/rest/resources/ConnectorsResource.java |  14 +-
 .../runtime/standalone/StandaloneHerder.java       | 105 ++--
 .../apache/kafka/connect/util/ConnectUtils.java    |  11 +
 .../connect/integration/BlockingConnectorTest.java | 431 ++++++++++++++
 .../kafka/connect/runtime/AbstractHerderTest.java  |  30 +-
 .../kafka/connect/runtime/WorkerConnectorTest.java | 161 ++++--
 .../apache/kafka/connect/runtime/WorkerTest.java   | 193 ++++---
 .../runtime/WorkerWithTopicCreationTest.java       | 194 ++++---
 .../runtime/distributed/DistributedHerderTest.java | 626 ++++++++++++++-------
 .../resources/ConnectorPluginsResourceTest.java    |  48 +-
 .../runtime/standalone/StandaloneHerderTest.java   | 265 +++++----
 .../util/clusters/EmbeddedConnectCluster.java      |  50 +-
 20 files changed, 2148 insertions(+), 782 deletions(-)
 copy connect/{api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java => runtime/src/main/java/org/apache/kafka/connect/runtime/CloseableConnectorContext.java} (65%)
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java