spring-kafka Examples and Free Source Code

AmqpConnectException: ConnectException: Connection refused: connect...

microservices spring-cloud spring-cloud-stream spring-kafka spring-rabbit

Spring Cloud Stream Kafka Error channel...

java spring spring-cloud-stream spring-kafka

Overridden onMessage of MessageListner not getting called in Spring Kafka Consumer Unit Test...

spring-boot mockito spring-kafka

How to apply spring.cloud.stream.kafka.bindings configuration property to all consumers...

java spring spring-boot spring-cloud spring-kafka

Spring kafka , Does ConsumerSeekAware interface, onPartitionsAssigned method call when rebalancing...

spring-boot spring-kafka

Why is my kafka listener not working in my Unit Test...

unit-testing spring-kafka

Kafka Consumer: Stop processing messages when exception was raised...

java apache-kafka kafka-consumer-api spring-kafka

Kafka configuration for Spring Integration on Spring Boot...

spring-boot spring-integration spring-kafka

Issue while using Multiple KafkaProducerMessageHandler with spring integration...

spring-integration kafka-producer-api spring-kafka mapr-streams

Sending message to Kafka on dynamically created topic gives error LEADER_NOT_AVAILABLE...

java spring spring-boot spring-kafka

Spring cloud stream application quits after one garbage input...

spring spring-cloud spring-cloud-stream spring-kafka

Avoiding Kafka Streams to start in tests using Spring Boot 1.5...

java spring-boot apache-kafka-streams spring-kafka spring-boot-test

Spring Cloud Stream determine topic Kafka message came from...

java spring spring-cloud-stream spring-kafka

Issues encountered switching from RabbitMQ to Kafka...

spring-integration spring-cloud-stream spring-kafka

kafka producer always retry connect...

spring-cloud-stream spring-kafka spring-cloud-sleuth

Kafka Implementation for Rest API...

spring-boot apache-kafka kafka-consumer-api kafka-producer-api spring-kafka

Conditional forwarding of messages using @SendTo on @KafkaListener...

java spring spring-kafka

Spring Kafka-Difference between configuring KafkaTemplate with Producer Listener and registering a c...

java spring spring-kafka

Topic not found error during application load test of a Spring Kafka application...

java spring-boot spring-test spring-kafka

How do I silence the "both methods have same erasure yet neither overrides the other" warn...

java spring-kafka

Spring Kafka- Trying to understand how things work behind the scenes...

java spring spring-kafka

Spring Kafka Transaction - Duplicate messages published to topic...

apache-kafka spring-transactions spring-kafka

Spring Cloud Stream embedded header format (Kafka)...

java spring-cloud-stream spring-kafka

Spring Kafka KafkaTemplate.flush() required?...

java apache-kafka spring-kafka

How to handle events from kafka lister using POJO's?...

java spring-boot spring-kafka

org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method threw java.lang...

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect spring-kafka

How to recover from exceptions sent by producer.send() in Spring Cloud Stream...

spring-cloud spring-kafka

How to prioritize some messages using spring cloud stream with the kafka binder...

spring-cloud-stream spring-kafka

In Spring-Kafka which method does the same thing like onPartitionsRevoked?...

apache-kafka spring-kafka

Spring Kafka Consumer/Listener Group...

apache-kafka spring-kafka