Lukasz Frankowski
Lukasz Frankowski
The copied link is also with `HEAD` but I've found the culprit - it's *Check commit on remote* feature. If this feature is enabled, the link is appropriate, if disabled,...
Added some :)
I no longer remember this case well, but doesn't this patch do it exactly?
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
Might try to look at this, but for that I'd have to know one thing. This is called non-transactionally from `KafkaMessageListenerContainer.ListenerConsumer.batchAfterRollback()` and transactionally from `KafkaMessageListenerContainer.ListenerConsumer.recordAfterRollback()`. Is there any reason for...
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
@sobychacko Hello. I planned to submit something here but the end of the year is a bit hot in my company and I haven't found time yet, so feel free...
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
To bo more specific: I use `DefaultAfterRollbackProcessor` but as a delegate through `CompositeKafkaAfterRollbackProcessor` which implements composite pattern, to allow to define different rollback strategies by topic.
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
@sobychacko not in this year probably :(
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
I will try to prepare something this week
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
Hello, that was difficult to return to this subject after longer pause, but tried to check what's going on and prepared small tester https://github.com/l0co/spring-kafka-2878-testcase. This is not a bug, though,...
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
Do you mean `this.transactionTemplate`? Yes, this component is not available here but I think we could use `kafkaTemplate.executeInTransaction(OperationsCallback callback)` instead.