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