Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

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?

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