[Solved] Kafka2.3.0 Error: Timeout of 60000ms expired before the position for partition could be determined

Flink consumption kafka2.3.0, wrong report, wrong partition allocation

Kafka Client Timeout of 60000ms expired before the position
 for partition could be determined

I found a wave on the Internet, but I didn’t find the reason. Later, I found that it was because of Kafka’s configuration file, server. Properties,   The host name is used as the configuration, which is added in server. Properties

Host. Name = 192.168.0.30 (the IP address of the current server is OK), and each Kafka node should be equipped with its own IP address


Read More: