Artem Bilan

Well, the behavior with the `maxConcurrentConsumers` is correct. It point is to increase to that number and keep them. That's something similar to the `concurrentConsumers` where all of them are...

The number of opened channels can be limited by the `CachingConnectionFactory`, which is `25` by default. > While with some workloads this is a natural state of the system, long...

If `basicCancel` does not work for you, then probably there is no any other more "soft" immediate termination. Feel free to raise a contribution and we will be happy to...

There is a `CompositeRecordInterceptor` which is exactly for such a use-case. You probably have to disable that `ConcurrentKafkaListenerContainerFactoryPostProcessor` and use its logic in your own `CompositeRecordInterceptor` definition with your own...

We will discuss this internally with the team. However I still feel that `BeanPostProcessor` is wrong direction to do that stuff. It would be better to design a consumer of...

That JavaDoc has to be fixed. The logic there in the `RetryableTopicAnnotationProcessor` is like this: ``` private KafkaOperations getKafkaTemplate(@Nullable String kafkaTemplateName, String[] topics) { if (StringUtils.hasText(kafkaTemplateName)) { Assert.state(this.beanFactory != null,...

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

More info in: https://github.com/rabbitmq/rabbitmq-consistent-hash-exchange

Well, it is possible even right now. You just use a `CustomExchange` instance when declare it from the application context. Although I still see a benefit in having a top-level...

@tetrade , thank you for the report! I'd be happy to fix the problem, but I don't understand how to read that object tree. Yes, I do see `RabbitMessageFuture` and...