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 0.10.2.2
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
request.timeout.ms 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.'
max.in.flight.requests.per.connection 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