Artem Bilan

Isn’t that partition assigned / revoked API about? Shouldn’t we adjust our maps respectively ?

Thank you, @bky373 , for investigation! So, according to your findings it looks like the problem is even reproducible with Spring for Apache Kafka, but really with plain Apache Kafka...

Well, when it is an ERROR that means something is wrong with an application. In our case the partitions assignment on the broker is out of our control. At least...

I think I'm fine with the plan. Let's see some PR from you! The WARN is enough for now: we can come back to the `PartitionNotAssignedEvent` when someone requests.

This makes sense. Feel free to contribute the fix: https://github.com/spring-projects/spring-kafka/blob/main/CONTRIBUTING.adoc Thanks

You can get an idea from here: https://github.com/artembilan/sandbox/tree/master/amqp-to-webflux. Unfortunately the request neither belongs to Spring for Apache Kafka, nor Spring WebFlux. This is something even outside of Spring Boot scope....

OK. Sounds like very complex application, which is indeed out of this project scope. Saying that here are some pointers on what I see so far: I don't see a...

I find this as a reasonable request. I'd like to have a fix for today's releases, but I don't see yet how to fix it. @LokeshAlamuri , any chances that...

The logic there is like this: ``` private void checkAdjust(boolean receivedOk) { if (receivedOk) { if (isActive(this.consumer)) { this.consecutiveIdles = 0; if (this.consecutiveMessages++ > SimpleMessageListenerContainer.this.consecutiveActiveTrigger) { considerAddingAConsumer(); this.consecutiveMessages = 0;...

Another piece of logic is like this: ``` boolean receivedOk = receiveAndExecute(this.consumer); // At least one message received if (SimpleMessageListenerContainer.this.maxConcurrentConsumers != null) { checkAdjust(receivedOk); } ``` So, if this `maxConcurrentConsumers`...