Venkata Rama Puppala created APEXMALHAR-2524:
------------------------------------------------
Summary: In kafka input operator commit errors are not handled
correctly
Key: APEXMALHAR-2524
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2524
Project: Apache Apex Malhar
Issue Type: Bug
Affects Versions: 3.7.0
Reporter: Venkata Rama Puppala
In kafka input operator commit errors are not handled correctly.
When below exception happens, the consumer is not able to continue to
poll/fetch messages from kafka.
internals.ConsumerCoordinator (ConsumerCoordinator.java:handle(544)) - Error
UNKNOWN_MEMBER_ID occurred while committing offsets for group
org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be
completed due to group rebalance
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
