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

Posted to commits@pulsar.apache.org by "relief-melone (via GitHub)" <gi...@apache.org> on 2023/05/24 08:00:01 UTC

[GitHub] [pulsar] relief-melone edited a comment on the discussion: Should Kafka Source Connector itsself after unrecoverable error?

GitHub user relief-melone edited a comment on the discussion: Should Kafka Source Connector itsself after unrecoverable error?

Thanks for the answer. I think that mitigation is an option for the kafka sink connector no? In the Kafka source connector you should have a Kafka Consumer and a Pulsar Producer. In our case the failing thread was the Kafka Consumer though. Since a Consumer that has been removed from the consumer group cannot be recovered I'd interpret the current behaviour as a bug then no? The consumer in that case should either be recreated or the process should exit.

GitHub link: https://github.com/apache/pulsar/discussions/19880#discussioncomment-5986386

----
This is an automatically sent email for commits@pulsar.apache.org.
To unsubscribe, please send an email to: commits-unsubscribe@pulsar.apache.org