[jira] [Created] (APEXMALHAR-2401) AbstractKafkaPartitioner to throw an exception after failing to contact Kafka to get topic metadata

["Sanjay M Pujare (JIRA)" <ji...@apache.org>]

Sanjay M Pujare created APEXMALHAR-2401:
-------------------------------------------

             Summary: AbstractKafkaPartitioner to throw an exception after failing to contact Kafka to get topic metadata
                 Key: APEXMALHAR-2401
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2401
             Project: Apache Apex Malhar
          Issue Type: Bug
            Reporter: Sanjay M Pujare
            Assignee: Sanjay M Pujare


Currently the AbstractKafkaPartitioner continues and returns to the caller even if it is unable to contact the Kafka broker. We should fix this behavior by  changing the AbstractKafkaPartitioner so that it fails and throws an exception after doing multiple retries of contacting the Kafka broker to get topic metadata. The exception will be caught and logged by Stram in a StramEvent which helps user debug the situation.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)