The cfml-kafka from davidsf

cfml-kafka's People

Contributors

Stargazers

Watchers

cfml-kafka's Issues

the consumer does not work

Hi @davidsf
I am testing your code with the latest version of kafka and it works fine with send.

But with consumer, I get this error:

[2021-05-27 17:59:22,251] INFO [GroupCoordinator 0]: Dynamic Member with unknown member id joins group ciccio2 in Empty state. Created a new member id consumer-23-9ff8b19b-9664-4617-a032-6302124b7160 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator)
[2021-05-27 17:59:22,252] INFO [GroupCoordinator 0]: Preparing to rebalance group ciccio2 in state PreparingRebalance with old generation 2 (__consumer_offsets-42) (reason: Adding new member consumer-23-9ff8b19b-9664-4617-a032-6302124b7160 with group instance id None) (kafka.coordinator.group.GroupCoordinator)
[2021-05-27 17:59:22,254] INFO [GroupCoordinator 0]: Stabilized group ciccio2 generation 3 (__consumer_offsets-42) (kafka.coordinator.group.GroupCoordinator)
[2021-05-27 17:59:22,257] INFO [GroupCoordinator 0]: Assignment received from leader for group ciccio2 for generation 3 (kafka.coordinator.group.GroupCoordinator)
[2021-05-27 17:59:22,284] INFO [GroupCoordinator 0]: Member[group.instance.id None, member.id consumer-23-9ff8b19b-9664-4617-a032-6302124b7160] in group ciccio2 has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-05-27 17:59:22,285] INFO [GroupCoordinator 0]: Preparing to rebalance group ciccio2 in state PreparingRebalance with old generation 3 (__consumer_offsets-42) (reason: removing member consumer-23-9ff8b19b-9664-4617-a032-6302124b7160 on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-05-27 17:59:22,288] INFO [GroupCoordinator 0]: Group ciccio2 with generation 4 is now empty (__consumer_offsets-42) (kafka.coordinator.group.GroupCoordinator)

could you help me or give me some suggestions?

thank you,
Ivan