Handling ‘no records available’ during ConsumerSeekAware seekToTimestamp
Solution for Handling ‘no records available’ during ConsumerSeekAware seekToTimestamp is Given Below: The requirement is to consume only those records …
kafka-consumer-api
Lag in spring boot kafka consumer? how to fix?
Solution for Lag in spring boot kafka consumer? how to fix? is Given Below: I work with the spring boot …
Timeout expired while fetching topic metadata – Kafka
Solution for Timeout expired while fetching topic metadata – Kafka is Given Below: We are trying to consume the broker …
Config to make Kafka client.id required
Solution for Config to make Kafka client.id required is Given Below: client.id in Kafka consumers is optional, so is there …
Which is better auto register schema or manual register in confluent schema registry?
Solution for Which is better auto register schema or manual register in confluent schema registry? is Given Below: I’m trying …
How to enable AIOKafkaConsumer to Consume a Kafka Topic starting from the Most Recent Message with a Certain Value
Solution for How to enable AIOKafkaConsumer to Consume a Kafka Topic starting from the Most Recent Message with a Certain …
kafka consumer.poll() method is getting blocked for max.poll.interval.ms seconds
As per documentation, max.poll.interval.ms is the time before which processor thread must complete processing. Otherwise, rebalancing will trigger. Time interval …
Kafka unable to produce/consume message
I’ve got a Kerberos SASL_SSL enabled Kafka authentication and the default kafka.security.authorizer.AclAuthorizer authorization setup in place. All the necessary ACLs …
Unable to read data from kafka topic
I’m a beginner in kafka. Trying to code a spark application to read data from a kafka topic created. Kafka …
What does a dash represents in CURRENT-OFFSET
Referring below screenshot of consumer-group description, i am trying to understand what does “-” means here for CURRENT-OFFSET. Does it …