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

8

**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

2

**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