camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nuge <rngu...@rocketmail.com>
Subject Re: camel-kafka: consumer heartbeat
Date Thu, 26 May 2016 17:21:04 GMT
Top level route is consuming from Kafka and then sub-routes are invoked via
seda (async).

It appears the consumer is being marked 'dead' and is attempting to
reconnect with the old generationId of the consumer group.

consumerRequestTimeoutMs=30000
heartbeatIntervalMs=5000

Have tried different values for heartbeatIntervalMs, but no difference.

2016-05-25 14:57:20,313 [d-test]] INFO  AbstractCoordinator            -
Marking the coordinator 2147483155 dead.
2016-05-25 14:57:20,696 [d-test]] ERROR ConsumerCoordinator            -
Error ILLEGAL_GENERATION occurred while committing offsets for group myGroup
2016-05-25 14:57:20,697 [d-test]] WARN  ConsumerCoordinator            -
Auto offset commit failed: Commit cannot be completed due to group rebalance
2016-05-25 14:57:20,708 [d-test]] ERROR ConsumerCoordinator            -
Error ILLEGAL_GENERATION occurred while committing offsets for group myGroup
2016-05-25 14:57:20,708 [d-test]] WARN  ConsumerCoordinator            -
Auto offset commit failed:
2016-05-25 14:57:20,714 [d-test]] INFO  AbstractCoordinator            -
Attempt to join group myGroup failed due to unknown member id, resetting and
retrying.
2016-05-25 15:00:49,958 [d-test]] INFO  AbstractCoordinator            -
Marking the coordinator 2147483155 dead.



--
View this message in context: http://camel.465427.n5.nabble.com/camel-kafka-consumer-heartbeat-tp5783116p5783129.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message