spring-kafka Examples and Free Source Code

Spring KafkaTemplate not handling errors on partition number...

java apache-kafka spring-kafka

@KafkaListener setting properties using SpEL expression...

spring-boot apache-kafka spring-kafka spring-el

How can I create a KafkaConsumer during runtime? (In Spring Boot)...

java spring-boot apache-kafka spring-kafka

Spring Kafka listener to consume JSON and infer the domain object...

json spring-boot apache-kafka spring-kafka json-deserialization

How to write Unit test case for adding callback for ListenableFuture...

unit-testing junit concurrency mockito spring-kafka

Kafka Consumer not retrying a message that has been failed to process...

java apache-kafka spring-kafka

Spring Kafka MANUAL_IMMEDIATE Acknowledge Only Commits 1 Highest Offset of 1 Partition...

spring spring-boot apache-kafka spring-kafka

Different Blocking retry for Main and non blocking topic...

spring-kafka

Obtaining kafka topics produced and consumed by a microservice...

apache-kafka spring-kafka

@KafkaListener __listener not available in BeanExpressionContext in Spring 3.0.1, works in v2.7.8...

spring spring-boot kotlin apache-kafka spring-kafka

Spring Kafka - In Memory Grouping Consumer Timeout Mechanism...

spring spring-boot apache-kafka spring-kafka

Restoration of GlobalKTables is extremely slow...

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

reason behind spring.json.trusted.packages...

spring-kafka

Validating Spring Kafka payloads...

validation spring-boot bean-validation spring-kafka

Spring Kafka Event Listener not seeing any Application Events...

java apache-kafka spring-kafka

Ignore Kafka message type headers...

java spring-kafka

When to use multiple ConcurrentKafkaListenerContainerFactory with Spring Kafka?...

spring-boot apache-kafka spring-kafka

How to measure the total time of an asynchronous process using Kafka topics?...

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

Difference between 3 apps setConcurrency(1) vs 1 app setConcurrency(3)...

java kubernetes apache-kafka spring-kafka

Delay the start of message consumption...

java apache-kafka spring-kafka reactor-kafka

How to enable deliveryAttemptHeader to get DefaultErrorHandler retry count when using spring cloud s...

spring-boot spring-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

How to retry in kafka with separate retry topics and exponentional backoff...

spring-kafka

Kafka AdminClientConfig ignoring provided configuration...

java apache-kafka spring-kafka

Spring kafka JsonSerializer to payload with map with null key throws exception...

spring jackson spring-kafka

CommonErrorHandler not present in kafka spring?...

spring spring-boot spring-mvc apache-kafka spring-kafka

KafkaMessageListenerContainer how to do nack for specific error...

spring-kafka

How to manually acknowledge on the listener?...

spring-kafka

Understanding relationship between ConcurrentKafkaListenerContainerFactory and KafkaMessageListenerC...

java spring-boot apache-kafka spring-kafka

Add partitions for Kafka topic dynamically using Spring Boot?...

java apache-kafka spring-kafka

NotEnoughReplicasException: Messages are rejected since there are fewer in-sync replicas than requir...

java apache-kafka spring-kafka