spring-kafka

spring-kafka copied to clipboard

Events skipped in group rebalancing

19

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** Between 3.1.7 and 3.2.5 **Describe the bug** The topic has 12 partitions. Consumers are automatically scaled as...

ejba

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/3804 Originally posted by **vitorsalves** March 15, 2025 Hi everyone, Quick question, in a recent project i had to implement serval KafkaListener all with similar annotations and...

artembilan

Outdated DLT Topic Suffix in `DeadLetterPublishingRecoverer` Method Documentation

1

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.3.0 **Describe the bug** The class [DeadLetterPublishingRecoverer](https://github.com/spring-projects/spring-kafka/blob/main/spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java) still contains references to the old DLT topic suffix (.DLT)...

fcappi

How does kafka send delayed messages?

2

How does kafka send delayed messages?

SilenceShine

Configure if message goes to DLQ after retries conditionally, based on MessageHeaders and thrown Exception

6

**Expected Behavior** I should be able to decide if message goes to DLT based on MessageHeaders predicate. I want to provide classes that implement something like the interface ```java @FunctionalInterface...

santunioni

Make `ContainerPausingBackOffHandler` working in batch mode.

15

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.3.1 **Describe the bug** Intention was to process entire batch of messages as a single entity and...

user734879

Add a way to pass objects as values for @KafkaListerner properties

3

**Expected Behavior** Have a way to pass objects or bean references as values for `@KafkaListener` properties (KafkaConsumer properties). For example to use the bean reference `#{__listener.filterPredicate}` as a configuration property...

geertvb

Fixes: #3697 Change the logic in the DelegatingInvocableHandler.invoke()

ivamly

Optimize a `MessagingMessageListenerAdapter` returning `null` from the `DelegatingInvocableHandler.invoke()`

4

Right now the `DelegatingInvocableHandler.invoke()` always returns an `InvocationResult` even if `result == null`. In the end we may just have a log message like: ``` Async result is null, ignoring...

artembilan

Align default behavior of `@RetryableTopic` and `RetryTopicConfigurationBuilder` with documentation

4

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** Since 3.2.0 **Describe the bug** The default behavior of @RetryableTopic (SINGLE_TOPIC) differs from both RetryTopicConfigurationBuilder (MULTIPLE_TOPICS) and...

bky373