Hi, We use a custom Kafka spout in our Apache Storm topology. When a machine in the Kafka cluster is bounced, we see the following error message in the logs:
ERROR ConsumerCoordinator [thread-iii] - [Consumer clientId=consumer-1, groupId=xxxxx] Offset commit failed on partition yyyy at offset nnn: The request timed out. I understand Kafka's enable.auto.commit is not allowed in Storm 1.1.1. Please help me understand what is the consequence of this timeout: - Is a tuple lost or reprocessed? - Is the tuple processed out of order (at a later time)? Thank you Ramin
