spring-kafka

spring-kafka copied to clipboard

Prevent message being reprocessed endlessly many times if using isStopContainerWhenFenced and message cannot be processed because of transaction timeout

1

**Affects Version(s):** 2.6.9 🎁 Enhancement (proposal) Context: non batch transaction processing As we know ProducerFencedException can be caused by producer being fenced (in this case we assume that producers listener...

bartosz-stasikowski-projectdrgn

The `asyncAcks` feature now allows a reactive work load to run on the listener container thread. Add an adapter to avoid users having to implement boilerplate code.

garyrussell

b3 header is not propagated for @KafkaListener using @RetryableTopic

2

The b3 header generated by `spring-cloud-sleuth` for Kafka messages is not getting propagated to retry topics. The same message when sent to retry topic after an exception, has a new...

deepesh-verma

`onMessage` methods in *MessageListener should allow for checked exception throwing

7

One can use the `@KafkaListener` annotation in methods that throw checked exceptions. However, when implementing the `*MessageListener` interfaces, none of the `onMessage` methods allow for (checked) Exceptions to be thrown....

fcristovao

Support for KafkaProxy for @KafkaListener

10

I think it would be very helpful to have support for swapping out the "backend" of `@KafkaListener` to support connecting via the Kafka RESTProxy instead of the normal kafka-client. I...

nnordrum

GH-1549: Auto-Detect Type Mappings [DO NOT MERGE]

1

Resolves https://github.com/spring-projects/spring-kafka/issues/1549 Needs docs and some code might move to spring-messaging - see https://github.com/spring-projects/spring-framework/issues/25574

garyrussell

garyrussell

Consider to add Producer and Consumer Factories for CloudEvents Kafka support

4

See more info on the official CloudEvents GH project: https://github.com/cloudevents/sdk-java/tree/master/kafka In addition we can consider to implement a `RecordMessageConverter` to map to/from a Spring `Message` which could be handy interacting...

artembilan

Reactive ReplyingKafkaTemplate

3

Currently, `ReplyingKafkaTemplate.sendAndReceive` returns a `RequestReplyFuture`. This issue is a request for a reactive interface that would return `Mono` and/or `Flux` types instead. Potentially utilizing reactor-kafka to ensure fully non-blocking I/O....

dnitzan

JsonMappingException thrown when BinderHeaderMapper tries to deserialize a list of values retrieved by key Allow

1

**Affects Version(s):** 2.2.4 Upon receiving a `Message`, when `BinderHeaderMapper` tries to deserialize a list of values, namely **["GET","HEAD","OPTIONS"]**, retrieved by key named **Allow** from the source Header in its ```...

hanishi