'partition fetched by kafka conusmer does not match the requested partition

kafka-server: 2.12_2.7.1
kafka-client: org.springframework.kafka && spring-kafka && 1.3.0.RELEASE

Both kafka-server and kafka-client are running in k8s container and error occured in kafka-client periodly: Ignoring fetch response containing partitions {} since it does not match the requested partitions {}

Here is the log: consumer log

I wonder if anyone has encountered the same problem and is looking forward to solving it,thanks!



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source