Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in 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

KafkaTestUtils.getRecords() returns only first sent record

unit-testing spring-kafka

IllegalStateException: please consider configuring an 'ErrorHandlingDeserializer' in the value and/or key deserializer

Failed to start bean kafkaListenerContainer: java.lang.IllegalArgumentException

Kafka consumer error Cancelled in-flight API_VERSIONS request with correlation id 1 due to node -1 being disconnected

How to configure an UncaughtExceptionHandler in Spring Kafka Stream

Kafka enable.auto.commit values for each consumer

Spring Kafka batch error handler - DeSerialiser Error handling with manual commit

java spring-kafka

Spring boot 3 and Swagger ui java.lang.NoSuchMethodError: 'io.swagger.v3.oas.annotations.media.Schema$AdditionalPropertiesValue additionalProperties() [closed]

Infinite retry in spring kafka consumer @retryabletopic

EmbeddedKafka failed authentication due to: Unexpected handshake request with client mechanism PLAIN, enabled mechanisms are []

How to deal properly with CommitFailedException: "... it is likely that the consumer was kicked out of the group."?

Reading from beginning (offset = 0) of topic with Spring Kafka / Spring Boot

spring-boot spring-kafka