CODEWITHSUNDEEP
.netapache-kafkakafkaflow
James
James

Reputation: 541

Kafka Consumer InvalidOperationException

I have a Kafka consumer giving the exception below. What is this indicating and how can it be resolved? It seems like it is trying to consume from a queue that has nothing on it, but I'm not sure how that is happening.

enter image description here

I don't know if it is related but I'm also seeing items not being consumed from a topic. I have multiple topics being consumed so is there a way to determine which topic is receiving the exception.

Upvotes: 0

Views: 157

Answers (1)

Fanda
Fanda

Reputation: 3786

It seems there is not set the offset for your consumer group. Then you need to configure strategy, from what place you want to start to read. See this section in KafkaFlow documentation.

https://farfetch.github.io/kafkaflow/docs/guides/consumers/add-consumers#offset-strategy

Upvotes: 1

Related Questions