Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

@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

@KafkaListener with single Topic and single Partition

Receiving Kafka Key in spring boot kafka listener

How to have multiple kafka consumer groups in application properties

apache-kafka spring-kafka

Idempotent and Transactions

apache-kafka spring-kafka