項目啟動以后收不到Kafka發出的消息,日志輸出類似:
INFO [org.springframework.kafka.KafkaListenerEndpointContainer#1-7-C-1] org.apache.kafka.clients.consumer.internals.AbstractCoordinator [600] -| Marking the coordinator hdp1.ambari:6668 JPCDH2:9092 (id: 2147483371 rack: null) dead for group hiveconns
解決方法:
第一種:修改Kafka服務端配置,將所有的機器名修改為IP地址;
第二種:本地配置hosts文件映射機器名,Win10 在C:\Windows\System32\drivers\etc;
10.101.x.x hdp1.ambari