技術標籤：javakafkazookeeperkafkabug

任何kafkaAPI 都執行報錯，找了兩天的問題

    public static void main(String[] args) {
        // 配置kafka的配置檔案。
        Properties properties = new Properties();
        properties.put("metadata.broker.list", "master:9092");
        properties.put("request.required.acks", "1");
        properties.put("serializer.class", "kafka.serializer.StringEncoder");

        Producer<
 
Integer,String> producer = new Producer<Integer, String>(new ProducerConfig(properties));
        KeyedMessage<Integer,String> message = new KeyedMessage<Integer,String>("zzz","dawason");
        producer.send(message);

    }

報錯資訊如下：javaapi Failed to send messages after 3 tries

最終解決：
修改hosts下的master，應該是最初的時候配完後來改了！

192.168.137.90 master.com master
192.168.137.91 service01.com service01
192.168.137.92 service02.com service02

成功！