and using
socket connect (Encoder/Decoder) for connecting consumer and producer.
Regards,
Paresh Behede
back up again periodically
and the process repeats. At some point we see that the rebalance starts
failing since the old zookeeper client's are still in connected state.
Wanted to know if anyone else has seen this problem.
thanks
Paresh
That is exactly what we are doing. But in the shutdown path we see the
following exception.
2013-12-19 23:21:54,249 FATAL [kafka.consumer.ZookeeperConsumerConnector]
(EFKafkaMessageFetcher-retryLevelThree)
[TestretryLevelThreeKafkaGroup_pshah-MacBook-Pro.local-1387494830478-efdbacea],
error du
exception around the call to stopConnections().
Please confirm if my understanding is correct.
thanks
Paresh
This is on the 0.8.0-beta1 code base. So if I understand right, moving to
0.8.0 should not cause the above problem? Is there a specific change that fixes
this behaviour change in 0.8.0?
Paresh