spring-kafka

spring-kafka copied to clipboard

Add test for next generation consumer-group rebalance protocol

17

Starting with `3.7.0`, the Kafka client now supports a new consumer group rebalance protocol and categorizes the consumer-group strategy as legacy (classic) vs. consumer. Spring for Apache Kafka supports the...

sobychacko

GH-2381 : Support kafka parallel-consumer

9

### Introduction Hi, Spring Team. This is chickenchickenlove, huge fan of you guys. I saw this issue ([Support kafka parallel-consumer](https://github.com/spring-projects/spring-kafka/issues/2381)), and this comment as well! > No plans currently; but...

chickenchickenlove

GH-2806 : Receiving an empty list when using RecordFilterStrategy on batch messages

6

### Motivation: - https://github.com/spring-projects/spring-kafka/issues/2806 - In the current `batch` mode, even if the `RecordFilterStrategy` filters all records resulting in an `Empty List` being returned, the `KafkaListener` is still invoked. In...

chickenchickenlove

Receiving an empty list when using RecordFilterStrategy on batch messages

2

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2805 Originally posted by **m-hetz** September 11, 2023 Hi! I'm using `RecordFilterStrategy` to filter records based on headers. This works great on single messages, the filter works...

artembilan

Enable KafkaStreamsMicrometerListener based on configuration

5

Spring Kafka provides `KafkaStreamsMicrometerListener`, which currently has to be added to the `StreamsBuilderFactoryBean` programmatically. There should be a configuration/property that supports adding a default listener automatically. This is similar to...

singhbaljit

Spring Kafka does not allow multiple headers with same key

6

I'm using Spring Kafka 3.1.2 Apache Kafka allows to have multiple headers with same key, but Spring Kafka limits that. Sample project reproducting the issue is available here: https://github.com/poznachowski/sample-spring-kafka-headers When...

poznachowski

DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method

15

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** For example: 2.8.11 (but see in the currrent master as well) **Describe the bug** In `DefaultAfterRollbackProcessor` there's...

l0co

GH-3067: Draft of mapping multiple headers with same key

13

Draft of mapping iterable headers

poznachowski

[Suggestion] Refactor KafkaListenerConfigUtils to Use Enum for Constants Management

2

This pull request introduces a significant refactor to the KafkaListenerConfigUtils class, transitioning it from an abstract class to an enum named KafkaListenerConfigTypes. This change aims to enhance the management of...

JoeCP17

Support kafka parallel-consumer

21

**Expected Behavior** Enable parallel processing of the messages in single consumer. **Current Behavior** Single-threaded processing of the messages. **Context** Are there any plans to include `ParallelStreamProcessor` as an option for...

bojanv55