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

Posted to commits@kafka.apache.org by mi...@apache.org on 2020/01/30 10:44:13 UTC

[kafka] branch trunk updated (6b86af3 -> f217752)

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

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


    from 6b86af3  KAFKA-7658: Add KStream#toTable to the Streams DSL (#7985)
     add f217752  KAFKA-9360: Allow disabling MM2 heartbeat and checkpoint emissions (#7887)

No new revisions were added by this update.

Summary of changes:
 .../connect/mirror/MirrorCheckpointConnector.java  | 16 +++++-
 .../kafka/connect/mirror/MirrorCheckpointTask.java |  2 +-
 .../connect/mirror/MirrorHeartbeatConnector.java   | 14 +++++
 .../mirror/MirrorCheckpointConnectorTest.java      | 67 ++++++++++++++++++++++
 .../connect/mirror/MirrorConnectorConfigTest.java  | 14 +----
 .../mirror/MirrorHeartBeatConnectorTest.java       | 52 +++++++++++++++++
 .../connect/mirror/MirrorSourceConnectorTest.java  |  8 +--
 .../apache/kafka/connect/mirror/TestUtils.java}    | 26 ++++-----
 8 files changed, 164 insertions(+), 35 deletions(-)
 create mode 100644 connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java
 create mode 100644 connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorHeartBeatConnectorTest.java
 copy connect/mirror/src/{main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java => test/java/org/apache/kafka/connect/mirror/TestUtils.java} (63%)