Top "Spring-kafka" questions

The Spring for Apache Kafka (spring-kafka) project applies core Spring concepts to the development of Kafka-based messaging solutions.

Simple embedded Kafka test example with spring boot

Edit FYI: working gitHub example I was searching the internet and couldn't find a working and simple example of an …

spring-boot apache-kafka spring-kafka
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

I am manually starting Zookeeper, then Kafka server and finally the Kafka-Rest server with their respective properties file. Next, I …

spring-boot apache-kafka kafka-consumer-api spring-kafka
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
How to acknowledge current offset in spring kafka for manual commit

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

java apache-kafka spring-kafka
Kafka Streams with Spring Boot

I want to work with Kafka Streams real time processing in my spring boot project. So I need Kafka Streams …

spring-boot apache-kafka apache-kafka-streams spring-kafka
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
Kafka error deserializing key/value for partition

I've got an integration tests that passes when I send to a Kafka topic without a key. However, when I …

java spring-boot apache-kafka spring-kafka
Spring Kafka The class is not in the trusted packages

In my Spring Boot/Kafka application before the library update, I used the following class org.telegram.telegrambots.api.objects.…

java spring-boot apache-kafka spring-kafka
Error to serialize message when sending to kafka topic

i need to test a message, which contains headers, so i need to use MessageBuilder, but I can not serialize. …

apache-kafka kafka-producer-api spring-cloud-stream spring-kafka