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.
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.
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