spring-kafka

spring-kafka copied to clipboard

ConcurrentMessageListenerContainer isChildRunning API is returning false even though active MessageListenerContainer instances are processing messages.

10

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.1.3 **Application** SpringBoot application uses spring-kafka module to consume and process the messages. MessageListenerContainer concurrency is 4....

LokeshAlamuri

@RetryableTopic not working for asynchronous @KafkaListener return types

5

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.2.0 **Describe the bug** When using the `@RetryableTopic` annotation on a Listener that returns a `CompletableFuture`, no...

matthiasValuecloud

Support customer-defined MessagConverter in @KafkaListener annotated method.

1

**Steps**: 1. Create a POJO by avro maven plugin: 1.1. Add `avro-maven-plugin` in `pom.xml`. ```xml org.apache.avro avro-maven-plugin 1.11.0 generate-sources schema ${project.basedir}/src/main/resources/schema-registry ${project.basedir}/src/main/java ``` 1.2. Add avro file (SampleMessage.avsc) in src/main/resources...

rujche

Calling `.nack()` suspends consumer group rebalance

11

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** I tested the following versions, they all show the same behaviour: 2.3.13, 2.5.14, 2.6.3, 2.8.2 **Describe the...

tkornai

read-committed breaks async-acks

2

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.2.0 **Describe the bug** KafkaMessageListenerContainer (at line 2041) assumes that offsets are contiguous. This is not true...

fdutton

Pause a consumer for X minutes

4

**Expected Behavior** @Component @KafkaListener(topics = {"job.cache"}, groupId = "cache-consumer") public class JobCacheConsumer { private static Cache cache = new MongoDbCache(); @KafkaHandler @RetryableTopic( backoff = @Backoff(delay = 10_000, multiplier = 2,...

jwreiser

Prevent Embedded Kafka logs auto delete

3

**Expected Behavior** A flag to prevent logs deletion on embedded-kafka shutdown. **Current Behavior** All logs will be deleted on shutdown. **Context**

Deepak16031

Docs say `defaultRetryTopicKafkaTemplate` is the default template bean name. `@RetryableTopic` javadoc says `retryTopicDefaultKafkaTemplate`

2

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** Between (at least) 2.9.13 and 3.2.4 **Describe the bug** The [documentation states](https://docs.spring.io/spring-kafka/reference/retrytopic/retry-config.html#using-the-retryabletopic-annotation) that the default `KafkaTemplate` bean...

ndwhelan

Code example in the documentation for Dynamically Creating Containers - Prototype Beans (Kotlin) is wrong

1

Spring Kafka 3.2.4 In the documentation for Dynamically Creating Containers - Prototype Beans (Kotlin) the example throw exception. It should be as follow instead ```kotlin class MyPojo(val id: String, val...

mohamedmelfiky

Bumps the development-dependencies group with 1 update: [org.springframework.boot:spring-boot-starter](https://github.com/spring-projects/spring-boot). Updates `org.springframework.boot:spring-boot-starter` from 3.2.9 to 3.2.10 Release notes Sourced from org.springframework.boot:spring-boot-starter's releases. v3.2.10 :lady_beetle: Bug Fixes management.health.db.ignore-routing-datasources=true has no effect when an...

dependabot[bot]