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

Posted to commits@pulsar.apache.org by yu...@apache.org on 2023/06/30 18:23:52 UTC

[pulsar] branch master updated (d83c7a6cc16 -> c5237eaeeee)

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

yubiao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from d83c7a6cc16 [fix][fn] Exit JVM when main thread throws exception (#20689)
     add c5237eaeeee [fix][io] Close the kafka source connector got stuck (#20698)

No new revisions were added by this update.

Summary of changes:
 pulsar-io/kafka/pom.xml                                    |  6 ++++++
 .../org/apache/pulsar/io/kafka/KafkaAbstractSource.java    | 14 ++++++++------
 .../pulsar/io/kafka/source/KafkaAbstractSourceTest.java    |  6 +++++-
 3 files changed, 19 insertions(+), 7 deletions(-)