GitHub user htbmw added a comment to the discussion: Should Kafka Source Connector itsself after unrecoverable error?
Looking at the code here, the log entry "Kafka source stopped" is missing from the above excerpt. https://github.com/apache/pulsar/blob/master/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java#L144-L157 Could it be that something goes wrong in the close() method and the source isn't properly stopped? GitHub link: https://github.com/apache/pulsar/discussions/19880#discussioncomment-6161875 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
