Artem Bilan

First of all we develop here a library of components and really don't experience with target production projects. Secondly, it would be great to have some simple project from you...

That's strange. The `completionTimeout` is already `30 seconds` by default... The reconnect must be handled by the client. Apparently both of you are using very old, out of support, Spring...

Closed as `Works as Designed`. Or at least the problem is not on Spring Integration side.

Well, sounds like you are over complicating. So, what is `to not send to DLT conditionally`? Mostly it means process the record as normal: if no exception, then nothing to...

I think this would be something like new module `spring-integration-ignite`. Sure, the `IgniteMetadataStore` could be as a first component in that module. We are opened for contribution: https://github.com/spring-projects/spring-integration/blob/main/CONTRIBUTING.adoc Thank you!

Let me try to summarize the concern! You have a custom `ConsumerInterceptor` which supposed to resolve that custom `filter.predicate` property into a bean from the application context. That `interceptor.classes` is...

I think with `3.3.7` you mean Spring Boot version. Spring for Apache Kafka for that one is `3.2.6`. I don't think the `producer creating` phase is supposed to be included...

Please, take a look into the sample I propose for the project code base: https://github.com/spring-projects/spring-kafka/pull/3699.

Moving to Backlog since we haven't have a chance to look into this.

Be our guest, @chickenchickenlove ! We have some other priorities to dig out, but will more than happy to review a possible fix or discuss some specific details . Thank...