[receiver/kafka] In k8s, 2 pods as consumer, but only one pod can connect Kafka

[XMingG99]

Component(s)

receiver/kafka

What happened?

Description

Now, we contribute Otel-collector as image, and running in k8s. There are two pods here, both in the "running" state. However, only one can connect to Kafka. Then, the other pod that cannot connect to Kafka is killed. After it restarts, it can connect to Kafka again (Kafka has three partitions). k8s's resource type is "statefulset", so pods are running one by one.

Collector version

v0.108.0

Environment information

Environment

kubernetes v1.23

OpenTelemetry Collector configuration

No response

Log output

no error log

Additional context

No response

[github-actions]

Pinging code owners:

• receiver/kafka: @pavolloffay @MovieStoreGuy

See Adding Labels via Comments if you do not have permissions to add labels yourself.