kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mimai...@apache.org
Subject [kafka] branch trunk updated (6b86af3 -> f217752)
Date Thu, 30 Jan 2020 10:44:13 GMT
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%)


Mime
View raw message