Not rebalancer consumer from kafka

Hi.
I have on topic with 3 partitions in kafka cluster and my graylog cluster is 3 node. I create Raw/Plaintext Kafka with Global (all graylog cluster node) when I start input only two node graylog start consume from kafka! but I know according to Kafka’s architecture, every node must be assign a partition and consume has to be balanced, but that doesn’t happen. should I do something special?

he @david_graylog13

what Graylog Version did you use?

@jan
Graylog Version: Graylog 3.1.1
I checked, when set Processor threads with 1 balance is established, but if set Processor threads > 1 balance is not established. but we need Processor threads e.g set 9 thread, each partition consume with 3 thread.
thanks.

that might be a bug in the code - do you mind checking Github if that is already known and if not, create a bug report?

thanks

I checked again completely. please look at the screenshots.




I create bug reporter.

This topic was automatically closed 14 days after the last reply. New replies are no longer allowed.