-
Notifications
You must be signed in to change notification settings - Fork 73
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Few consumers not consuming messages from partitions #127
Comments
Rdkafka-dotnet is not maintained anymore, please move to https://github.com/confluentinc/confluent-kafka-dotnet which replace it With rdkafka or confluent Kafka, you should not create 40 consumers in the same process - create a single one which subscribe to whole topics, and dispatch message to workers thread if needed (via concurrent queue for example), or dispatch to multiple process machines (you should not observe this though, so feel free to post more details in confluent repo!) |
Hello. I haven't created 40 consumers in same process. We have 40 instances with same consumer group each having one thread for consuming messages from Kafka. Patterns we are seeing are not constant. Current issue we see that out of 40 consumers only 36 consumers are able to map with partition and consuming messages. Do you have any idea how this could be possible and what needs to be done to fix this issue. |
Can you please specify if you are using rdkafka or confluent-kafka and version&os&some code snippets? Thks! |
Hello,
We have set 40 partitions and created 40 consumer threads. However, only 36 consumers are able to consume messages rest 4 consumers are not getting any messages. Could you please know in what scenario this can be possible and how to resolve that. Is there a way, we can manually link partition to consumer thread?
The text was updated successfully, but these errors were encountered: