spring-kafka Examples and Free Source Code

Batch Consumer not working with Kafka for CloudEvents using Spring Cloud Stream...

spring-boot spring-kafka spring-cloud-stream cloudevents

Spring-Kafka BatchInterceptor don't work as expected...

java spring spring-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

define non retryable exception in kafka...

apache-kafka kafka-consumer-api spring-kafka

Parallel processing and auto scaling in spring-kafka KafkaListener...

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

how to manual acknowledge kafka message without the use of @kafkalistener...

java apache-kafka spring-kafka

How do I get a Kafka message before the @KafkaListener method?...

java spring apache-kafka spring-kafka

spring jpa crud repository fetching old data from DB in multithreaded environment...

java spring-boot jpa spring-data-jpa spring-kafka

Is kafka container factory a requirement in Spring Kafka?...

java spring apache-kafka spring-kafka

Kafka: Different Deserializers For Different Topics...

java spring-boot apache-kafka spring-kafka

Starting multiple Kafka listeners in Spring Kafka?...

spring-kafka

Send multiples DTOs using Kafka Template...

java spring-boot apache-kafka spring-kafka

Kafka ConsumerInterceptor onCommit not being called when using transactions...

spring-boot kotlin apache-kafka spring-kafka

How can I test that I have configured ChainedKafkaTransactionManager correctly in my spring boot ser...

spring spring-boot transactions spring-kafka

When using @KafkaListener in springboot, how to set idleBetweenPolls...

spring-boot spring-kafka

How to determine a Kafka consumer's offset...

apache-kafka spring-kafka

Using Multiple Kafka Listeners to handle specific data types on a shared topic...

java apache-kafka spring-kafka

How to add a header in Spring Cloud Streams...

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

How can I define two or more Kafka consumers using spring boot configurations?...

apache-kafka spring-kafka kafka-consumer

Configuring ReplyingKafkaTemplate for getting the responses from multiple topics...

apache-kafka kafka-consumer-api spring-kafka

Is it a problem if I set spring.json.trusted.packages = '*' while consuming data in Spring C...

spring-kafka spring-cloud-stream json-deserialization spring-cloud-stream-binder-kafka spring-cloud-stream-binder

Spring Kafka doesn't autocreate topics...

java spring-boot apache-kafka spring-kafka

Combining blocking and non-blocking retries in Spring Kafka...

spring-kafka

error handling when consume as a batch in kafka...

apache-kafka kafka-consumer-api spring-kafka

Opportunity to catch, log, and rethrow exception when an exception occurs in kafka listener containe...

spring spring-kafka

check consumed partition and consumer for a message in kafka...

apache-kafka kafka-consumer-api spring-kafka

How to use Spring Boot Autoconfiguration for Spring Kafka's exactly once delivery?...

spring-kafka

UnsupportedOperationException when using RetryableTopic...

apache-kafka spring-cloud spring-kafka opentracing

How to provide topic specific properties in Spring Kafka?...

spring spring-boot apache-kafka spring-kafka

how does kafka batch listener concurrency work with multiple topics...

java apache-kafka spring-kafka

Create a KStream out of a string passed...

apache-kafka spring-kafka