[jira] [Created] (APEXMALHAR-2506) Kafka Input operator - needs better handling of failure of Kafka reader thread

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

[jira] [Created] (APEXMALHAR-2506) Kafka Input operator - needs better handling of failure of Kafka reader thread

JIRA jira@apache.org
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)
Loading...