Artem Bilan

The logic around this header is not that simple as it sounds. See `FailedRecordTracker` for details.

That's correct. But the problem with the rest of missing API that we deal with the whole batch. Therefore it is not clear how to inject that `KafkaHeaders.DELIVERY_ATTEMPT` header and...

Sure! Any one can take an issue for contribution. I am personally, don't see a quick and easy solution, and with limited amount of time resources on my side, not...

I cannot find too much information about this in the Internet: https://stackoverflow.com/questions/44911123/how-to-use-sql-server-service-broker-with-java. However if you see how this could be implemented with plain JDBC, based on those specific command, you...

Yes, saw that doc, but it still does not mandate how to use that stuff from Java or at least JDBC. It looks more like Transact SQL which is for...

@gdupontf , thank you for sharing that! Really good and readable code. However those `connection.prepareStatement()` don't provide any gain over existing feature with JDBC-backed `QueueChannel`. Sure! On the SQL Server...

Closed as `Won't Fix` since suggestion PoC has nothing to do with Spring Integration.

There is a Kafka property `group.initial.rebalance.delay.ms`: https://stackoverflow.com/questions/56561378/how-to-introduce-delay-in-rebalancing-in-case-of-kafka-consumer-group. You can try to play with that. Without some sample to reproduce hard to judge what is wrong on Spring side. Thanks

Right. See more info in the official Apache Kafka docs: https://kafka.apache.org/documentation/ > A new config, group.initial.rebalance.delay.ms, was introduced. This config specifies the time, in milliseconds, that the GroupCoordinator will delay...

I don't know those details of Apache Kafka consumer implementation. That is out of Spring scope. We will look into this together with @sobychacko when we have a chance. Meanwhile...