Closed runerys closed 9 months ago
This ran successfully for me on the Docker Compose stack we have in the examples directory 👍
Ah, brilliant! 👌
I got up and running, but somehow the consumer don't get any assignments through consumer.Subscribe()
.
2023-12-19 10:26:34 [2023-12-19 09:26:34,402] INFO [GroupCoordinator 1]: Dynamic member with unknown member id joins group noda-time-example-c1819734-03c2-4ca9-8c9e-a8a0f3f96499 in Empty state. Created a new member id rdkafka-b3203d0b-55ea-4ed0-8a4b-7b6456bccdd6 and request the member to rejoin with this id. (kafka.coordinator.group.GroupCoordinator)
2023-12-19 10:26:34 [2023-12-19 09:26:34,405] INFO [GroupCoordinator 1]: Preparing to rebalance group noda-time-example-c1819734-03c2-4ca9-8c9e-a8a0f3f96499 in state PreparingRebalance with old generation 0 (__consumer_offsets-34) (reason: Adding new member rdkafka-b3203d0b-55ea-4ed0-8a4b-7b6456bccdd6 with group instance id None) (kafka.coordinator.group.GroupCoordinator)
2023-12-19 10:26:34 [2023-12-19 09:26:34,406] INFO [GroupCoordinator 1]: Stabilized group noda-time-example-c1819734-03c2-4ca9-8c9e-a8a0f3f96499 generation 1 (__consumer_offsets-34) with 1 members (kafka.coordinator.group.GroupCoordinator)
2023-12-19 10:26:34 [2023-12-19 09:26:34,411] INFO [GroupCoordinator 1]: Assignment received from leader rdkafka-b3203d0b-55ea-4ed0-8a4b-7b6456bccdd6 for group noda-time-example-c1819734-03c2-4ca9-8c9e-a8a0f3f96499 for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator)
However, direct assignment worked fine: consumer.Assign(new TopicPartition(Topic, 0));
So, I also got it running (quite) successfully.
Huh, yeah, I recreated everything and got the same problem. Everything should still work if we remove the check and set auto.offset.reset
to earliest
; going with that for the other examples: https://github.com/ch-robinson/dotnet-avro/commit/5c95d0a8702e4bd140ee63107005888631fc8038
Thanks! I rebased my branch and updated the setting. Works now.
The issue https://github.com/ch-robinson/dotnet-avro/issues/222 requests a demonstration on how to enable NodaTime support. This PR constributes an example for schema generation, serialization and deserialization.
Note that
This PR is setup as a draft for now, since: