You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2020/02/14 22:35:17 UTC

[kafka] branch trunk updated (8d0b069 -> 16ee326)

This is an automated email from the ASF dual-hosted git repository.

jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 8d0b069  KAFKA-9557: correct thread process-rate sensor to measure throughput (#8112)
     add 16ee326  KAFKA-9556; Fix two issues with KIP-558 and expand testing coverage (#8085)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   1 +
 .../kafka/connect/runtime/WorkerSinkTask.java      |   7 +-
 .../kafka/connect/runtime/WorkerSourceTask.java    |   8 +-
 .../runtime/distributed/DistributedHerder.java     |  23 +-
 .../runtime/rest/resources/ConnectorsResource.java |  41 +--
 .../connect/storage/KafkaStatusBackingStore.java   |  14 +-
 .../java/org/apache/kafka/connect/util/Table.java  |   3 +
 .../ConnectorTopicsIntegrationTest.java            | 321 +++++++++++++++++++++
 .../integration/MonitorableSinkConnector.java      |   2 +
 .../runtime/distributed/DistributedHerderTest.java |  39 ++-
 .../rest/resources/ConnectorsResourceTest.java     | 107 ++++++-
 .../storage/FileOffsetBackingStoreTest.java        |   3 +
 .../storage/KafkaStatusBackingStoreFormatTest.java | 243 +++++++++++++++-
 .../storage/KafkaStatusBackingStoreTest.java       | 141 ++++++---
 .../util/clusters/EmbeddedConnectCluster.java      |  49 ++++
 .../clusters/EmbeddedConnectClusterAssertions.java |  42 +++
 16 files changed, 957 insertions(+), 87 deletions(-)
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorTopicsIntegrationTest.java