Artem Bilan

Any chances that you can contribute that fix: https://github.com/spring-projects/spring-kafka/blob/main/CONTRIBUTING.adoc? Thanks

I think the problem comes from the `MethodKafkaListenerEndpoint.createMessageListenerInstance()`: ``` if (isBatchListener()) { BatchMessagingMessageListenerAdapter messageListener = new BatchMessagingMessageListenerAdapter( this.bean, this.method, this.errorHandler); ``` where we have: ``` public class BatchMessagingMessageListenerAdapter extends MessagingMessageListenerAdapter...

Merged as https://github.com/spring-projects/spring-kafka/commit/f91f8a918688ccf855207aa66ef5703da0568770. @chickenchickenlove , thank you very much for the contribution (again)! A couple notes: - it is better to use `@SuppressWarnings("unchecked")` if you cannot fix cast warnings in...

Well, merged, so closing

I does only `KafkaStreamsMetrics` for the `MeterRegistry`. I understand that observability covers metrics as well, but that might confuse users since there is no tracing for Kafka Streams yet. Either...

Well, that is a `DefaultKafkaHeaderMapper` behavior. Feel free to implement any custom one which would populate a list of values into the target message header. I don't treat this is...

Spring for Apache Kafka `2.5.x` is out of support: https://spring.io/projects/spring-kafka#support. Consider to upgrade to the latest one. Also it is not clear what is "Delete the message offset"? I was...

I concur with @fabiobauer . When we done with the record in the particular step of the retry, we really don't need it in that retry topic any more. It...

It was never intended to be used that way, but rather direct instance provided for that `DefaultKafkaProducerFactory` where you already have a configured `ObjectMapper` injected. But I still see your...

Would you mind to share with us a code which causes that problem? Thanks