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

Posted to commits@kafka.apache.org by rh...@apache.org on 2021/03/01 16:05:18 UTC

[kafka] branch trunk updated (d78a923 -> a63e5be)

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 d78a923  KAFKA-12329; kafka-reassign-partitions command should give a better error message when a topic does not exist (#10141)
     add a63e5be  KAFKA-10340: Proactively close producer when cancelling source tasks (#10016)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/connect/runtime/Worker.java   |  2 +-
 .../kafka/connect/runtime/WorkerSourceTask.java    | 38 +++++++++++++-----
 .../apache/kafka/connect/runtime/WorkerTask.java   |  4 ++
 .../integration/ConnectWorkerIntegrationTest.java  | 45 ++++++++++++++++++++--
 .../kafka/connect/integration/ConnectorHandle.java |  8 ++--
 .../integration/MonitorableSourceConnector.java    |  1 +
 .../connect/runtime/ErrorHandlingTaskTest.java     |  3 +-
 .../ErrorHandlingTaskWithTopicCreationTest.java    |  3 +-
 .../connect/runtime/WorkerSourceTaskTest.java      |  5 ++-
 .../WorkerSourceTaskWithTopicCreationTest.java     |  5 ++-
 .../apache/kafka/connect/runtime/WorkerTest.java   |  4 +-
 .../runtime/WorkerWithTopicCreationTest.java       |  4 +-
 12 files changed, 98 insertions(+), 24 deletions(-)