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(-)
