Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

Getting only a single record out of many the first time kafka consumer gets a record?

KafkaTemplate send method safe to use without manual (blocking) check of returned future

Spring cloud streams could not autowire Source.class

EmbeddedKafka failing since Spring Boot 2.6.X : AccessDeniedException: ..\AppData\Local\Temp\spring.kafka*

Should i rethrow an interrupt when catching an InterruptedException in the catch block when doing a KafkaTemplate.send?

spring-kafka

spring MessageConversionException when deserialzing an avro object

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