Use for questions related to the Apache Kafka consumer API
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-apiAny idea how to set group name when consuming messages in kafka using command line. I tried with the following …
apache-kafka kafka-consumer-apiI 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-apiI 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-streamsI 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-kafkaI have a simple class to consume messages from a kafka server. The majority of codes are copied from the …
java apache-kafka kafka-consumer-apiI 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-apiWant 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-apiWith 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-kafkaI 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