spring-kafka Examples and Free Source Code

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

Spring Boot: Using SSL Bundles for spring-kaka MATLS...

java spring-boot spring-kafka

Testing Kafka consumer @KafkaListener with EmbeddedKafka in Spring Boot...

spring-boot mockito spring-kafka

spring kafka No type information in headers and no default type provided...

spring spring-boot apache-kafka spring-kafka

How to handle the exception at consumer ion Spring?...

spring apache-kafka spring-kafka

Kafka Consumer Unable To Resolve Listener Method Intermittently...

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

Kafka - Deserializing the object in Consumer...

java apache-kafka spring-kafka

Spring aspect on kafka listener interface...

spring spring-kafka aop

Spring Kafka Producer not sending to Kafka 1.0.0 (Magic v1 does not support record headers)...

spring spring-boot apache-kafka docker-compose spring-kafka

Avro serialization problem in case of optional logicalType...

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

How to use Spring Stream Application supplier as a proxy?...

spring-integration spring-kafka spring-cloud-stream spring-cloud-function spring-cloud-stream-binder

GlobalKTable as QueryableStore with Kafka Streams Binder...

apache-kafka spring-kafka apache-kafka-streams spring-cloud-stream spring-cloud-stream-binder-kafka

Synchronising transactions between database and Kafka producer...

apache-kafka spring-transactions spring-kafka distributed-transactions

java.lang.RuntimeException: non-nullable field authBytes was serialized as null from Spring Boot to ...

spring apache-kafka spring-kafka azure-eventhub

Running Spring Boot application with Kafka in Docker-compose...

java docker apache-kafka docker-compose spring-kafka

Difference between KafkaTemplate and KafkaProducer send method?...

java spring-boot apache-kafka spring-kafka

How to handle Kafka container lifecycle using spring kafka in Kubernetes multipod deployment...

java spring kubernetes spring-kafka

Blocking call in @KafkaListener spring boot...

spring-boot apache-kafka spring-kafka project-reactor