Gary Russell

Admininistration functionality for [Simple|Direct]MessageListenerContainer via jmx

2

### Discussed in https://github.com/spring-projects/spring-amqp/discussions/1520 Originally posted by **rfelgent** October 18, 2022 Hi @all, at my company we have created code that exposes basic admininistration functionality for `[Simple|Direct]MessageListenerContainer`: the so called...

Incorrect SimpleRetryPolicy Documentation

1

The [documentation](https://docs.spring.io/spring-batch/docs/current/reference/html/retry.html#retryPolicies) talks about `setRetryableExceptions()` and `setFatalExceptions()`. These methods don't exist; instead retryable exceptions (and not) are provided in a Map via a constructor. See https://stackoverflow.com/questions/62836985/simpleretrypolicy-spring

MessagingException.failedMessage is raw payload instead of converted value

1

`FunctionInvocationWrapper` `invokeConsumer()` and `invokeFunction()` should create a `Message` with the converted payload and throw a `MessageHandlingException` with that message. Consider the following: ```java @SpringBootApplication public class So76610419Application { public static...

Given:  and  I would like to see "discards" linked to a "top" (or some...

Handling connection errors with KafkaTemplate when cluster not available

4

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2250 Originally posted by **Walnussbaer** May 3, 2022 Hi everyone, I'm really strunggeling with some basic functionality that I would like to achieve using KafkaTemplate and I...

Spring Kafka Listener trying to convert String Payload to int

1

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2205 https://github.com/spring-projects/spring-kafka/discussions/2205#discussioncomment-4302539

Have one consumer for retry topics

3

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2146 Originally posted by **psh05** March 4, 2022 Currently there is one consumer per topic. If an app consumes from multiple topics which will implement multiple retries...

The `asyncAcks` feature now allows a reactive work load to run on the listener container thread. Add an adapter to avoid users having to implement boilerplate code.

GH-1549: Auto-Detect Type Mappings [DO NOT MERGE]

1

Resolves https://github.com/spring-projects/spring-kafka/issues/1549 Needs docs and some code might move to spring-messaging - see https://github.com/spring-projects/spring-framework/issues/25574