Logstash kafka input consumer group not finding all partitions

Elastic Stack Logstash
1

I have a topic with two partitions but logstash consume only one of them.
"Adding newly assigned partitions: partition-0", it is missing the other partition. And when I delete my logstash pod (I'm on kubernetes) it randomly assigns a partition.

this is my input configuration:

input {
     kafka {
       bootstrap_servers => "X"
       topics => "topic-x"
       consumer_threads => 1
       }
     }

Can someone help fix this?
Thank you in advance

2

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