Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

Spring Boot: how to use FilteringMessageListenerAdapter

spring-boot spring-kafka

SpringBoot, Kafka : java.lang.NoSuchMethodError: org.apache.kafka.clients.producer.Producer.close(Ljava/time/Duration;)V

Spring Kafka error: This error handler cannot process 'SerializationException's directly; please consider configuring an 'ErrorHandlingDeserializer'

Kafka producer JSON serialization

spring-kafka application.properties configuration for JAAS/SASL not working

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