Top "Kafka-consumer-api" questions

Use for questions related to the Apache Kafka consumer API

Topics, partitions and keys

I am looking for some clarification on the subject. In Kafka documentations I found the following: Kafka only provides a …

apache-kafka kafka-consumer-api kafka-producer-api
how to set group name when consuming messages in kafka using command line

Any idea how to set group name when consuming messages in kafka using command line. I tried with the following …

apache-kafka kafka-consumer-api
Kafka consumer for multiple topic

I have a list of topics (for now it's 10) whose size can increase in future. I know we can spawn …

java multithreading apache-kafka kafka-consumer-api
Kafka: Consumer API vs Streams API

I recently started learning Kafka and end up with these questions. What is the difference between Consumer and Stream? For …

apache-kafka kafka-consumer-api apache-kafka-streams
Kafka producer TimeoutException: Expiring 1 record(s)

I am using Kafka with Spring-boot: Kafka Producer class: @Service public class MyKafkaProducer { @Autowired private KafkaTemplate<String, String> …

apache-kafka kafka-consumer-api kafka-producer-api spring-kafka
Simple Kafka Consumer Example not working

I have a simple class to consume messages from a kafka server. The majority of codes are copied from the …

java apache-kafka kafka-consumer-api
Kafka console consumer ERROR "Offset commit failed on partition"

I am using a kafka-console-consumer to probe a kafka topic. Intermittently, I am getting this error message, followed by 2 warnings: [2018…

apache-kafka kafka-consumer-api
Kafka - Delayed Queue implementation using high level consumer

Want to implement a delayed consumer using the high level consumer api main idea: produce messages by key (each msg …

java scala messaging apache-kafka kafka-consumer-api
Spring Boot Kafka: Unable to start consumer due to NoSuchBeanDefinitionException

With in my spring boot service while trying to start a kafka consumer seeing NoSuchBeanDefinitionException and unable to start the …

spring apache-kafka kafka-consumer-api spring-kafka
How to use Spring Kafka's Acknowledgement.acknowledge() method for manual commit

I am using Spring Kafka first time and I am not able to use Acknowledgement.acknowledge() method for manual commit …

java spring-boot kafka-consumer-api spring-kafka