Sandesh created APEXMALHAR-2506:
-----------------------------------
Summary: Kafka Input operator - needs better handling of failure
of Kafka reader thread
Key: APEXMALHAR-2506
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2506
Project: Apache Apex Malhar
Issue Type: Improvement
Reporter: Sandesh
Kafka input operator has a separate thread to read from Kafka. Even if the
Kafka reader thread is not running, the operator will continue to run.
Ideally, following things needs to be done
1. More logging as to why the Kafka reader thread exited
2. If the Kafka reader thread gets killed either kill the container or retry
with a new thread.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
