Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

When to use ExponentialBackOffPolicy vs FixedBackOffPolicy when setting retry policy for a kafka consumer in a Spring boot app?

apache-kafka spring-kafka

Gradle dependency with test classifier

java.lang.NoClassDefFoundError when running KafkaEmbedded for Unit test

Spring Kafka. Not started EmbeddedKafkaBroker

How to know when consumer.poll() is called while using @KafkaListener annotation?

Kafka Json consumer error java.lang.NoSuchFieldError: READ_UNKNOWN_ENUM_VALUES_USING_DEFAULT_VALUE

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?