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