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