Artem Bilan

Any reasoning for this, please? In most cases the Embedded Kafka is used for testing, where those logs are created in temporary folder which indeed is cleared after test suite...

I would suggest then to use a real one or based on Testcontainers. Even if we can fix `EmbeddedKafkaZKBroker` for its logic: ``` CoreUtils.delete(kafkaServer.config().logDirs()); ``` the `EmbeddedKafkaKraftBroker` is based on...

Confirmed. For example `KafkaTemplate`: ``` @Override public CompletableFuture sendDefault(@Nullable V data) { ``` but `KafkaOperations`: ``` CompletableFuture sendDefault(V data); ``` And there are many other similar to this missing annotations....

@LokeshAlamuri , can you confirm, please, that this piece of code from the `KafkaMessageListenerContainer` is guilty in the picture: ``` /** * Handle exceptions thrown by the consumer outside of...

> This is a bit design issue, where problem is not just with errorhandlers and stop API I see, so even if we check for `fenced` just before calling those...

OK. The `3.0.1` is still one of those out of support, but if you confirm that the problem is there even if supported version, we would like to ask you...

@SilenceShine , please, share much more info what are you talking about and emphasize how your concern is related to Spring at all? We just do not provide here support...

Hi @LokeshAlamuri ! Is the problem still present after we made the fix in the PR #3347? Thanks Can we treat this a duplication and close respectively?

Looking to your concern again, I would say that behavior is correct. It was always like that it is like that everywhere. The stopped state mean that this component does...

The `DefaultErrorHandler` does this: ``` private static CommonErrorHandler createFallback(BackOff backOff, @Nullable ConsumerRecordRecoverer recoverer) { return new FallbackBatchErrorHandler(backOff, recoverer); } ``` That `FallbackBatchErrorHandler` has this logic in its `handleBatch()`: ``` ErrorHandlingUtils.retryBatch(thrownException,...