franz-go
franz-go copied to clipboard
Partition assignment to consumer in consumer-group is duplicated after consumer restart
Hi there, I have an issue that the same partitions assign to consumer 2 times in a row.
<133>1 2024-01-09T01:00:00.077418+00:00 microservice - - main: Start version=0.0.0 commit=...
<135>1 2024-01-09T01:00:00.098722+00:00 microservice - - kafka: Partition assigned topic=topic_name partition=0
<135>1 2024-01-09T01:00:00.098741+00:00 microservice - - kafka: Partition assigned topic=topic_name partition=1
<135>1 2024-01-09T01:00:00.486519+00:00 microservice - - kafka: Partition assigned topic=topic_name partition=0
<135>1 2024-01-09T01:00:00.487011+00:00 microservice - - kafka: Partition assigned topic=topic_name partition=1
This happened if reboot one consumer, and after ~5 minutes reboot the another one from one consumer-group. Can you take a look, please? Can I collect more information for you if needed?
Franz-go v1.15.4, Kafka v3.6.1