spring-kafka

spring-kafka copied to clipboard

The trace IDs are not being propagated.

2

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** "3.3.7" **Describe the bug** When enabling tracing in Spring Kafka using the following configuration: spring: kafka: template:...

fleszarnatalia

DefaultErrorHandler doesn't work with suspend methods

12

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.2.4 **Describe the bug** Suspend methods don't trigger the default error handler on exception **To Reproduce** I...

igloo12

Provide a sample with webflux to develop http rest api

3

**Expected Behavior** Create a sample with spring-kafka and spring webflux **Context** I need to develop a microservices with spring webflux to expose a set of http rest api to allow...

gianluca-sabena

Kafkaconsumer is not safe for multi-threading access

3

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** For example: 2.8.5 **Describe the bug** Caused by: java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access at...

ayush11-96

Adds the ability to add record interceptors instead of override them

5

**Expected Behavior** I'm using a Spring Cloud Steam `ListenerContainerCustomizer` to customize a `AbstractMessageListenerContainer` in order to add a record interceptor. I would expect to be able to add a record...

Nyamiou

**Expected Behavior** there is docs **Current Behavior** [there is no docs](https://docs.spring.io/spring-kafka/reference/retrytopic/dlt-strategies.html) (on this page at least) **Context** I'm investigating DLT and retry flows with spring-kafka however, I stumbled on the...

StephenFlavin

**Version(s) of Spring for Apache Kafka** 3.4 **Description** I want to use ReplyingKafkaTemplate in order to implement Request-Reply messaging pattern with Kafka having end-to-end transactionality. I have tried many solutions...

periplanomenos

Add an option to only commit consumer offsets for records that are not filtered out using RecordFilterStrategy

8

**Expected Behavior** When using a RecordFilterStrategy in combination with an AckMode like RECORD, only the consumer offsets of the records that have been handled, should be committed. Suggestion: Add a...

geertvb

Forbid fenced Container to stop ConcurrentContainer

7

[DRAFT] Fixes #GH-3448 **Issue**: Fenced Child Container could stop the running ConcurrentContainer **Fix**: Configure KafkaMessageListenerContainer (KMLC) to use ConcurrentMessagleListenerContainerRef instead of ConcurrentContainer. Internally, ConcurrentContainerRef checks if KMLC is fenced when...

LokeshAlamuri

Hi all, please forgive me if I've misunderstood the current behaviour. Afaik when configured batch/manual mode if an acknowledge isn't called before the next batch starts the only recourse is...

jeacott1