spring-kafka Examples and Free Source Code

Can a single Spring's KafkaConsumer listener listens to multiple topic?...

spring spring-boot spring-kafka

Kafka streams correctly handles message but throws Deserialization exception...

java spring apache-kafka spring-kafka apache-kafka-streams

I am Getting an error: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication...

apache-kafka spring-kafka

How to set AbstractConsumerSeekAware on ConcurrentKafkaListenerContainerFactory?...

spring-boot spring-kafka

Kafka consumer reconnection after getting disconnected...

apache-kafka kafka-consumer-api spring-kafka

How to verify spring kafka producer has successfully sent message or not?...

spring-boot spring-kafka

List Kafka Topics via Spring-Kafka...

java apache-kafka kafka-consumer-api spring-kafka

Kafka Consumer test works with SpringBootTest but not with ContextConfiguration...

java spring spring-boot spring-kafka spring-boot-test

spring kafka producer initiated transaction not working as described in spring docs?...

spring-boot apache-kafka spring-kafka kafka-transactions-api

Avoid __TypeId__ and spring_json_header_types magic headers set by Spring Kafka...

java spring-kafka

What is the non deprecated way of setting the transaction manager into the listener container is spr...

spring spring-boot apache-kafka spring-kafka kafka-transactions-api

Spring Boot with Kafka - not logging exceptions on Deserialization when using DLQ...

java spring-boot spring-kafka

@KafkaListener with containerFactory is not triggered in @SpringBootTest...

spring-boot spring-kafka spring-boot-test testcontainers spring-boot-testcontainers

Issue with `bootstrap.servers` in Kafka Producer Configuration with Spring Boot 3.2.6 and Spring Clo...

java spring-boot spring-kafka spring-cloud-config

This error handler cannot process 'org.apache.kafka.common.KafkaException's; no record infor...

java spring spring-boot spring-kafka

@KafkaHandler in the consumer doesn't consume the topic message as an object class, only as a st...

spring-boot apache-kafka spring-kafka kafka-consumer-api java-17

Invoke Kotlin suspended function inside reactive stream...

kotlin apache-kafka spring-webflux kotlin-coroutines spring-kafka

a deployed mircoservice in AKS is not able to connect to deployed kafka in AKS...

kubernetes apache-kafka spring-kafka azure-aks

Java Memory Leak on creating many empty Maps...

java memory apache-kafka cpu spring-kafka

How can I conditionally deserialize a Kafka message based on some condition?...

spring-kafka spring-cloud-stream

Spring-Kafka usage of ConcurrentKafkaListenerContainerFactory for more than One @Kafkalistener...

java spring-boot apache-kafka spring-kafka

org.springframework.kafka.support.serializer.ErrorHandlingDeserializ' of type serializer.ErrorHa...

spring apache-kafka spring-kafka

Caused by: org.messaging.handler.annotation.support.MethodArgumentNotValidException: Could not resol...

spring apache-kafka spring-kafka

Implement Custom Error Handler for Batch Listener in Spring Kafka...

spring spring-boot apache-kafka spring-kafka

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer...

spring-boot apache-kafka kafka-consumer-api spring-kafka

Read from configuration kafkalistener...

java spring apache-kafka kafka-consumer-api spring-kafka

KafkaListener got "Caused by: org.springframework.messaging.converter.MessageConversionExceptio...

java apache-kafka spring-kafka avro confluent-schema-registry

Spring boot Kafka send objects between different microservices...

java spring-boot apache-kafka spring-kafka

Customized DeadLetterPublishingRecoverer not being invoked...

spring-boot spring-kafka

Cannot find Required type: BiConsumer...

java spring-boot apache-kafka spring-kafka