spring-kafka

spring-kafka copied to clipboard

Allow @Override of KafkaAdmin createAdmin()

3

**Expected Behavior** The Spring KafkaAdmin class has a package-private method "createAdmin" that returns the `org.apache.kafka.clients.admin.AdminClient` type: ```java AdminClient createAdmin() { return AdminClient.create(this.getAdminConfig()); } ``` It'd be great if this method...

anders-swanson

`CommonErrorHandler.isAckAfterHandle()` misleads developers in case of `false`

6

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** For example: At least between 2.8.x and current **Describe the bug** `CommonErrorHandler.isAckAfterHandle()` misleads developers in case of...

ioanngolovko

Fixes #3483 Changes the KafkaAdmin#createAdmin() method to be protected, returning the Admin interface instead of the AdminClient class. This change allows user of spring-kafka to supply their own Admin interface...

anders-swanson

**Expected Behavior** Provide a tondem RecordFilterStrategy with MessageConverter. **Current Behavior** MessageConverter invokes after RecordFilterStrategy logic. **Context** If we configure MessageConverter (Json for example) -> then we expect to filter the...

ioanngolovko

childContainer of previous run is stopping ConcurrentContainer after a new start

5

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.3 **Describe the bug** If a ConcurrentContainer is stopped, then the child container should not be allowed...

LokeshAlamuri

KafkaHeaders.DELIVERY_ATTEMPT is not added for batch listeners

8

Version 3.3.2 When using blocking retries for a batch listener, the attempt number is not coming in DELIVERY_ATTEMPT header even if setting `setDeliveryAttemptHeader(true)` The method `KafkaMessageListenerContainer.ListenerConsumer.internalHeaders` is called only in...

lm231290

kafka test jars are included in spring-kafka-test

6

The tests jar of [kakfa-clients](https://github.com/spring-projects/spring-kafka/blob/v3.3.4/build.gradle#L351) and [kafka-server-commons](https://github.com/spring-projects/spring-kafka/blob/v3.3.4/build.gradle#L355) are included in spring-kafka-test. Both include a _junit-platform.properties_ configuration file which results in `WARNING: Discovered 2 'junit-platform.properties' configuration files in the classpath; only...

rob-valor

Trace context is being reset in between retry attempts and dlt publication

1

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.3.0 **Describe the bug** I'm using `RetryTopicConfiguration` to configure the non blocking retries for my consumer. After...

msatmarean18

KafkaOperations is missing nullable annotations

1

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.3.3 **Describe the bug** `KafkaOperations` is in a package annotated with `@NonNullApi`, therefore all method parameters are...

gbaso

**Expected Behavior** wanna the the exact message sent to kafka server. as KafkaTemplate using generic, it's not same behavior when V is String and Object. **Current Behavior** no log for...

qingjiaorose157