Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

Filter messages before deserialization based on headers

spring-boot spring-kafka

Spring and Kafka - Multiple Consumers with same Group ID - Only one consumer gets the messages

ConcurrentMessageListenerContainer isn't acting concurrent

Does Spring Cloud Stream Kafka supports embedded headers?

Consume messages from Kafka only if some condition true

Spring Kafka - Encountering "Magic v0 does not support record headers" error

Spring Boot and Kafka: Broker disconnected

Spring boot Rest api with Spring Kafka

BATCH vs MANUAL and ack vs commit

apache-kafka spring-kafka

EmbeddedKafka sending messages to consumer after delay in subsequent test

Spring Kafka consumer not able to consume records

add kafka autoStartUp false in the ConsumerConfig

spring-boot spring-kafka

How do I deserialize a kafka message to a POJO?

EmbeddedKafka not working cause an Scala error

how to configure two instances of Kafka StreamsBuilderFactoryBean in spring boot

@KafkaListener vs ConsumerFactory groupId

Java set Kafka retention time in source code

unit testing ListenableFuture kafkaTemplate.send always returns null

Getting ProducerFencedException on producing record in Kafka listener thread