spring-kafka Examples and Free Source Code

Can I consume and produce multiple times in a single Kafka transaction?...

apache-kafka spring-kafka spring-cloud-stream-binder-kafka kafka-transactions-api

How to reprocess DLT messages after the underlying issues get fixed?...

spring apache-kafka spring-kafka

Single NullPointerException at spring-kafka startup...

java spring-boot spring-kafka

Which moment is preferable to programmatically start a listener/consumer in Spring Kafka?...

spring-kafka

Exception handling after migration from Spring Kafka 2.6 to 2.8+...

spring-kafka

Azure Event Hubs for Kafka with 2 consumers from the same group rebalance infinitely...

azure apache-kafka azure-eventhub spring-kafka

Is it possible to read a numeric value from application.yml for @RetryableTopic @Backoff in Kotlin?...

spring kotlin apache-kafka spring-kafka spring-el

Spring Kafka - Centralized @KafkaListener logging...

spring-boot spring-kafka

Limit number of messages from Kafka in Spring Batch...

java spring spring-boot spring-kafka concurrentlinkedqueue

Kafka consumer retry based on specific exceptions...

java spring spring-boot spring-kafka

Kafka Springboot - send topicName to producer on the fly...

java apache-kafka spring-kafka

Save data to Cassandra from Kafka using Spring Batch with high throughput...

spring-boot cassandra spring-batch spring-kafka batch-processing

Shutdown of the Spring Boot application without active Kafka Listeners...

spring spring-boot spring-kafka

How to synchronize transactions with Spring Tx?...

spring spring-data-jpa spring-kafka spring-data-mongodb spring-transactions

How to configure kafka for ssl.enabled.protocols in spring yml file...

spring-boot apache-kafka spring-kafka

How to edit message data before sending to DLT in Spring-Kafka...

spring-boot apache-kafka spring-kafka spring-retry

How to change amount of DELIVERY_ATTEMPT before fail in KafkaListener?...

java spring spring-boot apache-kafka spring-kafka

Getting the below exception io.confluent.kafka.schemaregistry.rules.RuleException when trying to add...

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

RetryTopicConfigurationSupport produces exception: Either a RetryTopicSchedulerWrapper or TaskSchedu...

spring spring-boot apache-kafka spring-kafka

SpringKafka handling retry failures...

java apache-kafka spring-kafka

Consuming messages in batch in Kafka using @KafkaListener...

java spring spring-boot apache-kafka spring-kafka

Spring Kafka consumer listener configuration...

spring-boot kotlin apache-kafka spring-kafka

How can I process @KafkaListener method in different threads?...

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

Why my Spring Kafka unit test almost ran into ProducerFencedException every time...

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

What acknowledgment strategy can I use when my incoming kafka message sends messages on multiple top...

java apache-kafka spring-kafka

transaction-id-prefix need to be identical for same application instance in spring kafka 3?...

apache-kafka spring-kafka spring-kafka-test kafka-transactions-api

Error when starting Spring Boot application that implements Kafka Streams...

spring-kafka apache-kafka-streams

Kafka Consumer - How can I do Replay/Get the same message from kafka broker in case my service is do...

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

Integration tests with Kafka and Testcontainers...

java spring-boot integration-testing spring-kafka testcontainers

What is the default kafka ack policy for @KafkaListener?...

java spring-boot spring-kafka