Artem Bilan

Right, @chickenchickenlove , that will work for some use-case. But I believe @Nyamiou 's request is more about `AbstractMessageListenerContainer` internals, where an `addRecordInterceptor()` API would be exposed to deal with...

What are your `1, 2, 3, 4`? Different scenarios, or steps, or states of the same scenario? Isn't this a result of all the changes you have introduced recently? >...

No problem! I will need more time to investigate this. We may ask if @sobychacko has some cycles to look into this quicker. Thanks

This is known issue: https://issues.apache.org/jira/browse/KAFKA-17121. You can try to exclude those dependencies, but I think somewhere in the `KafkaClusterTestKit` hierarchy some of those classes are used. We are right now...

Well, I see that issue has been fixed in Kafka `3.9.0`. You can just upgrade your project to that one: https://docs.spring.io/spring-kafka/reference/appendix/override-boot-dependencies.html

I am confused. If you use Confluent Kafka container then you don't need embedded Kafka at all. And might be the case that you don't need `spring-kafka-test` altogether. That did...

The mentioned `XTRIM` command can be used via `ReactiveStreamOperations`: ``` /** * Trims the stream to {@code count} elements. * * @param key the stream key. * @param count length...

I'm not sure what do you see wrong with that `ReactiveRedisStreamMessageHandler` and its `streamKeyExpression` property: ``` /** * Create an instance based on provided {@link ReactiveRedisConnectionFactory} and expression for stream...

I see the point of the request. However it supposed to be slightly different. The `KafkaTemplate` use `KafkaAdmin` to resolve just only `clusterId()`, which has nothing to do with the...

@joshiste , we have done the fix for that `UUIDConverter`: https://github.com/spring-projects/spring-integration/commit/77d8dfd0916ec39bd0bbfec6608253ea226bb847. The fix has nothing to do with this issue. Thank you for the report!