Hi : 
     My code works fine with local Kafka version 2.11, but when running the 
code by connecting kafka on remote server (managed with Cloudera), the 
following error message occurred:  
Group coordinator cahive-master02:9092 (id: 2147483391 rack: null) is 
unavailable or invalid, will attempt rediscovery


I tried to set advertised.hostname = localhost. Did not help the problem. 
Another error occurred: 



[Producer clientId=producer-1] Error while fetching metadata with correlation 
id 362 : {ciovInput_v1=LEADER_NOT_AVAILABLE}

[Producer clientId=producer-1] Error while fetching metadata with correlation 
id 363 : {ciovInput_v1=LEADER_NOT_AVAILABLE}

[Producer clientId=producer-1] Error while fetching metadata with correlation 
id 364 : {ciovInput_v1=LEADER_NOT_AVAILABLE}

[Producer clientId=producer-1] Error while fetching metadata with correlation 
id 365 : {ciovInput_v1=LEADER_NOT_AVAILABLE} ...










Thanks

Reply via email to