spring Kafka ConsumerFactory bean not found
How to re-send (read) an old kafka message from given topic and partition at specific offset using spring-kafka?
Spring Kafka JsonDesirialization MessageConversionException failed to resolve class name Class not found
Kafka manual acknowledge before Spring Boot shutdown
Getting BeanInstantiationException. in KafkaMessageDrivenChannelAdapter
The different between Kafka Topic, Spring-cloud-stream Channel and Spring-cloud-stream destination
Listener sending leave group request to kafka
How to deserialize kafka messages and publish event?
Listener stops receiving messages
Get topic name, partition and offset in case of container error handlers
Renew Kerberos Ticket with Spring Kafka
Spring Cloud Stream: Proper handling for StreamListener when it takes a long time to process the message
Spring Kafka @KafkaListener - Retry sending failed messages and manually commit the offset
A dependency autowired correctly in constructor gets null later on automatically for same Service object with KafkaListener
How to store only latest key values in a kafka topic
spring Kafka model is not in the trusted packages
Load in memory cache from kafka
Kafka Streams:Aggregate hourly message in Kafka
Spring Cloud Stream Kafka - Method must be Declarative
What should be an appropriate value for Kafka consumer concurrency (regard to scaling)?
Read again specific kafka messages after having read à lot
Mongo is missing data updates when using Update() with $inc ( update-in-place )
Kafka manual ackMode MANUAL_IMMEDIATE what if not acknowledge
Spring embedded kafka fails when I'm running tests
Kafka multiple consumer from different partitions
What happens when one consumer thread in ConcurrentKafkaListenerContainerFactory fails
How to fix 'Failed to update metadata after xxx ms' in spring-kafka when send record in callback
Programatically setting properties when using @KafkaListener
Kafka consumer picking up topics dynamically
Multiple Kstream @StreamListener
Get data from topic after pushing in @EmbeddedKafka in spring boot Junit
How to configure frequency for kafka consumer poll in spring-kafka
Kafka Listeners are getting active before spring boot application startup for Spring Kafka 2.2.3.RELEASE
Chance of callback not getting registered for springkafka-template send method
How to run kafka streams effectively with single app instance and single topic partitions?
How to run more than 1 application instances of ktable-ktable joins kafka streams application on single partitioned kafka topics?
Any example available for creating GlobalKTable using Spring cloud stream kafka-streams?
How to resolve MessageConversionException in spring-kafka?
Update Kafka commit offset after successful batch insert
How kafka consumer can deserialize different json objects?
Kafka listener receiving List<ConsumerRecord<String, String>>, is it possible to consume?
Spring kafka consumer not commits to kafka after leader changed
Deserializing different JSON payload from same Kafka topic with Spring Kafka
Update spring-kafka-test to 2.2.x but still use old kafka-client 1.1.1 with junit5 and spring boot 2
Propagate Spring boot security context into a bean annotated with @KafkaListener
Kafka Topic ordering with Spring Kafka
Filter Repeated Messages In Kafka
When using @KafkaListener can I get a reference to the underlying KafkaConsumer as I want to read the endOffsets
Is ReplyingKafkaTemplate blocking?
Is there a way to configure "waitTime"/Hold for messages in Spring-cloud-stream apps using Kafka, before sending to downstream apps?
Kafka Consumers get many replays when new consumers connect
cloud.stream.binding.BindingService : Failed to create consumer binding in Kubernetes(GKE)
Is there a compatibility issue or known bugs if i use spring-kafka 1.3.x with kafka-client v1.1.x?
Kafka broadcast. How to know read offsets for consumer group if the only consumer in the group goes down
How to close KStream if all brokers are not available
Question about using the @KafkaListener autoStartup = "false" for multiple topics
Is it possible to get exactly once processing with Spring Cloud Stream?
Method annotated with @KafkaListener not called if there are no messages
Spring Kafka thread naming convention
Unexpected failing/rebalancing of consumers
kafka send messages to all consumers that have the same group.id
What could cause Kafka serialization exception?
Get Failed Messages with KafkaListener
How not to lose messages from Kafka when database is offline
Spring Cloud kafka Stream - How to use two different kafka cluster for same channel?
KafkaStreams interactive queries with Spring-Kafka
spring kafka looking for the latest available message in a topic
Spring cloud stream schema deserialization compatibility with KafkaAvroSerializer enabled producers
How to access MessageHeaders in Kafka batch listener
Version compatibility of the kafka, Spring Cloud stream and Spring cloud stream binder kafka
Kafka Streams - Consumer memory overload
@KafkaListener sometimes received repeated messages
KStream send record to multiple streams (not Branch)
How to pass dynamic topic name to @kafkalistener(topics from environment variable
Kafka Template: Timeout Exception while sending the message by kafka template
Failed to create producer binding
Spring Kafka Listener on Http Request
Sending using KafkaTemplate<String, String> returns a exception for using String as a key
How to commit offset with ConsumerAwareErrorHandler when using concurrency?
Saved entity in a Spring Kafka Listener is not rollbacked on a transactional test
Spring Cloud Stream Kafka - Serde class not found: org.apache.kafka.common.serialization.Serde$StringSerde
How to read multiple types of json from one topic in kafka springboot
Issue while deserialising kafka message
How to catch warning "Broker may not be available" at the Spring Kafka Listener
Kafka Producer Time out
why does KafkaMessageListenerContainer never relinquish thread from executor?
How to implement AOP to set kafka offset to latest?
spring-integration-kafka: KafkaTemplate#setMessageConverter(RecordMessageConverter) has no effect
spring-kafka listener shutdown
Sending files as byteArray to kafka using spring kafka
spring-integration-kafka: Annotation-driven handling of KafkaProducerMessageHandler result?
Filter messages before deserialization based on headers
how to implement kafka template in spring project without spring-boot
After kafka crashed, the offsets are lost
what is compatable version of spring-kafka for spring framwork 2.1.0
Spring kafka error Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.transaction.KafkaAwareTransactionManager
Spring-Kafka with transactions, multiple threads
Spring Kafka listener using DeadLetterPublishingRecoverer and manual ack mode
KafkaListener annotation at class level with errorhandler property ignored
Kafka Spring: How to write unit tests for ConcurrentKafkaListenerContainerFactory and ConcurrentMessageListenerContainer?