Artem Bilan

Hey, @jonenst ! Please, take a look into the latest code. That is like this now: ``` private final List processorThreadsToInterrupt = Collections.synchronizedList(new ArrayList()); ... synchronized (this.processorThreadsToInterrupt) { this.processorThreadsToInterrupt.forEach(Thread::interrupt); }...

Any chances that you can share with us a simple project to reproduce on our side? Thanks

Yeah... Sorry, I have missed that `DefaultBinding.getEndpoint()` is not `public`. Yes, `ConsumerEndpointCustomizer` is a good choice instead. The logic there in the `IntegrationMBeanExporter` is like: ``` @Override public Object postProcessAfterInitialization(Object...

Forgot to mention: this is not only related to Kinesis binder. All others are also based on Spring Integration and have to follow similar JMX functionality. But that all makes...

Don't we need to expose such an auto-configuration property, @garyrussell , in Spring Boot? `RabbitProperties.Template` and `RabbitProperties.Listener` . For Spring Integration I did via `spring.integration.management.observationPatterns`

Right, `false` by default, but still easy to configure by convention instead of some customizers and so on.

I'm not sure in your concern. ``` List convertedHeaders = new ArrayList(); ``` Then: ``` if (this.headerMapper != null) { rawHeaders.put(KafkaHeaders.BATCH_CONVERTED_HEADERS, convertedHeaders); } ``` And we indeed can modify this...

May be we just need to look into a new pair of channel adapters based on Reactor Netty: https://projectreactor.io/docs/netty/release/reference/index.html#udp-server https://projectreactor.io/docs/netty/release/reference/index.html#udp-client ?

I would suggest to repurpose this issue into something like new `spring-integration-netty` module. And there we would look into a UDP part how to implement it based on the Netty...

The contribution is welcome: https://github.com/spring-projects/spring-kafka/blob/main/CONTRIBUTING.adoc!