Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

Recovering Kafka clients (consumers/producers) after they went down

Not acknowledging the kafka message at all in MANUAL_IMMEDIATE mode

How to choose Kafka transaction id for several applications, hosted in Kubernetes?

Spring boot Kafka Consumer Bootstrap Servers always picking Localhost 9092

How to configure kafka transaction manager with spring transaction in spring boot app

Problem with start of @KafkaListener (Spring)

spring kotlin spring-kafka

Kafka Cannot Configure Topics on Application Startup, but Later Can Communicate

SpringBoot Kafka + openjdk 17: org.xerial.snappy.SnappyError: [UNSUPPORTED_PLATFORM] pure-java snappy requires access to java.nio.Buffer raw address

SSE `this.eventSource.onmessage` call fails. Error `"EventSource's response has a MIME type ("application/json") that is not "text/event-stream"

Difference between Spring Kafka lib and native Kafka Java API

apache-kafka spring-kafka

Adding ConsumerRebalanceListener to the ConcurrentKafkaListenerContainerFactory

How to clear topics in tests with Spring Kafka

Exception Handling on sending a message via Kafka Template

No pending reply: ConsumerRecord

Kafka consumer fails silently to connect to broker

apache-kafka spring-kafka

Does ConcurrentKafkaListenerContainerFactory increases parallelism in consumption of messages from Kafka Topics

When should i use batch consumer vs single record consumer

spring-kafka

Difference between spring-cloud-stream-binder-kafka and spring-cloud-starter-stream-kafka

Stop consume message for Stream listener

spring-boot spring-kafka

Spring Kafka: Poll for new messages instead of being notified using `onMessage`