Thank you for answering RUI. Yeah, groups existes, one per partition.
No yet, trying to get access to them.
On Mon, Mar 25, 2024 at 3:41 PM Rui Abreu wrote:
>
> Having "no active members" is expected since the assignment of partitions is
> controlled by Spout instead of Kafka. However, the cons
Having "no active members" is expected since the assignment of partitions
is controlled by Spout instead of Kafka. However, the consumer group must
be present in Kafka in a healthy system
Have you check the broker logs for any errors?
On Mon, Mar 25, 2024, 19:03 Juan Pablo Garbora wrote:
> is no
is not present.
~ kafka-consumer-groups.sh --command-config
~/.kafka/kafka.production.properties --bootstrap-server
xxx.confluent.cloud:9092 --describe --grou Consumer group 'zzz' has no
active members.
On Mon, Mar 25, 2024 at 11:25 AM Rui Abreu wrote:
>
> Can you query your Kafka broker usin
Can you query your Kafka broker using Kafka's binaries and check if the
consumer group is present? (something like ./kafka-consumer-groups.sh
--bootstrap-server $broker:9092 --describe --consumer-group $consumerGroup)
And also check the broker side logs?
On Mon, 25 Mar 2024 at 16:19, Juan Pablo
got a Storm 2.6.0 with Kafka Spout (setting 32 parallelismHint) and
sometimes I'm getting:
Is this normal ?
Error
java.lang.RuntimeException: org.apache.kafka.common.KafkaException:
Unexpected error in commit: The group id does not exist.
at org.apache.storm.utils.Utils$1.run(Utils.java:413)
