How to read kafka topics on demand. (Java Spring Boot Application)

SeekToCurrentErrorHandler: DeadLetterPublishingRecoverer is not handling deserialize errors

Kafka does not consume messages

Spring Kafka 2.2.2 Consumer returns only one record instead of max-poll-records

Spring stream binds to String instead to pojo

Microservice health check never passed after Kafka connection failed

Spring-Kafka 1.3.9 is not compatible with Kafka client

Keeping entries in a state sotre just for a difined time

Spring Batch Kafka Kafka to Database Job

How to send List of Objects to kafka topic using spring-kafka framework?

Server sent event - Stream is not reconnecting after few disconnections

Confusion on implementing KStream / Table in Spring Boot

How to test bindings with useNativeEncoding=true in Spring Cloud Stream

skip retry mechanism and go straight to DLT

How to test(Integration tests) springboot-kafka microservices

Multiple message types per Kafka topic

Kafka Microservice Proper Use Cases

Different key.serializer per producer when using transactions

What is the proper @EmbeddedKafka usage for IntegrationTests?

Application should keep running even after Kafka connection is broken

How to enforce order of execution of KafkaListeners

how to get KafkaListener Consumer

How do I properly externalize spring-boot kafka-streams configuration in a properties file?

Kafka continuous rebalancing when slow consumer

Multiple Kafka Listeners With Same GroupId All Receiving Message

Failed to start the Construct Kafka Consumer

Unable to connect to kafka brokers by ssl - Spring Boot

How to monitor kafka consumer lag for transactional consumers

Java KafkaConsumer Client 2.0.1 compatibility with KafkaBroker 1.1.3

Invalid Keystore Format, BootStrap Broker Disconnected and Spring Kafka Synchronous Event Publishing with KafkaTemplate

Sending errors to Kafka retry topic with Spring Cloud Stream

Hystrix Stream using stream kafka

Integrating custom kafka consumer with Spring cloud config client

SASL_SSL integration with EmbeddedKafka

SPEL not working in KafkaListener. Not able to resolve property

spring kafka - transaction issue

Reset EmbeddedKafka After Every Test Method

Failed to construct kafka producer with Springboot

How to create a cluster of Nodes running Spring-Kafka consumers

Spring Cloud Stream configs for KTable input and output

Consuming from kafka topic using spring only on receiving certain events

How to fix 'Offset commit failed on partition com.application.iot.measure.stage-0 at offset 1053078427: The request timed out.' and Spring Kafka Producer Synchronous Event Publishing with KafkaTemplate

Benefit of Using Reactive Programming When Using Kafka

Queryable store is returning null on fetch a given topic

Spring-kafka-test testing JSON message with custom deserialization

Creating kafka topics with Java doesn't work

EmbeddedKafkaBroker set properties throws NoClassDefFoundError: kafka/zk/EmbeddedZookeeper

How @SentTo sends the message to related topic?

How to configure GlobalChannelInterceptor for spring-cloud-stream?

Kafka poll messages only when i use 5000ms poll

Is it possible to use kafka to respond to aggregate?

Kafka metrics don't appear to be updating correctly

How to test if method with @KafkaListener is being called

Spring App Not Connecting to Kafka with SSL

How to save messages (from Kafka) in batch (db) without lose the remaining ones?

Does Spring Kafka producer guarantee delivery by default?

Generic way to park messages from Kafka/RabbitMq after multiple retries

Reprocessing a message when an error occurs while processing it in the Kafka Stream

Kafka Producer and Consumer Issues

Kafka Stream Exception: GroupAuthorizationException

Spring @Recover and @Retry not working when org.springframework.util.concurrent.ListenableFuture throws Exception

How to stop my producer container/API in spring-integration with kafka extension

Getting Serialization exception while consuming from Kafka queue using Spring Boot

Multiple instances of same application with same group id kafka

Spring Cloud stream binder Kafka custom headers are not received in consumer

Which solution to schedule messages in a kafka environment

How to configure multiple kafka consumer in application.yml file

Spring-Cloud-Stream-Kafka Custom Health check is not giving Kafka status

Is it possible to have one Kafka consumer thread per topic?

Spring Application not getting terminate for timeout exception

How to set port in KafkaEmbedded when unit testing spring-kafka consumer

My kafka error handler is not getting invoked, should I invoke explicitly?

How to acknowledge kafka message read by the consumer using spring integration kafka

Transaction Synchronization in spring boot not working properly

Kafka multiple producers to specific same partition

Kafka delete records from the topic without using offsets but by a field of the record

Spring Kafka, manual commiting in different threads

In kafka, When producing message with transactional, Consumer offset doubled up

Clustered app - only one server at a time reads from kafka, what am I missing?

Transaction Synchronization in spring boot with Database+ kafka example

kafka does not have messages that producer sent

Offset out of range resetting offset 2nd consumer group

Spring Boot with Kafka : How to write unit Integration tests excluding kafka configuration

Why using containerGroup is preventing my other listeners to work?

How to read from the end of a topic, regardless of the group's committed offset

How to initialize an object before accepting http request

Kafka consumer health check

SpringBootTest fail if application contains @KafkaListener annotation

Kafka's JsonDeserializer not working for java.util.Map

How to handle errors in Kafka Consumer

How to set groupId to null in @KafkaListeners

consume min of n records and max n records but return records after waiting for m seconds

Setting up Kafka on Openshift with strimzi

REST API command with event driven choreography

Custom key serdes per binding in Spring Cloud Stream

Filter out messages before Kafka commits the offsets

How to have multiple kafka consumer groups in application properties

app is alive but stops consuming messages after a while