在宿主主機(jī)中使用java編程發(fā)消息給docker中的kafka，已經(jīng)做了端口映射，可是docker中的kafka收不到消息

如下圖，在docker中啟動(dòng)了kafka和zookeeper的服務(wù)，并且做了端口映射，
分別9192->9092 2281->2181

生產(chǎn)者：
kafka-console-producer.sh --broker-list localhost:9092 --topic t01

消費(fèi)者：
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic t01 --from-beginning

在docker中使用命令啟動(dòng)一個(gè)生產(chǎn)者和消費(fèi)者可以正常工作。

但是在宿主主機(jī)中，使用java編程創(chuàng)建一個(gè)生產(chǎn)者，代碼如下：

public class demo {
    public static void main(String[] args) {
        Properties conf = new Properties();
        conf.put("zookeeper.connect", "localhost:2281");
        conf.put("bootstrap.servers", "localhost:9192");
        conf.put("serializer.class", StringEncoder.class.getName());
        conf.put("key.serializer", StringSerializer.class.getName());
        conf.put("value.serializer", StringSerializer.class.getName());
        conf.put("acks", "all");
        KafkaProducer<String, String> kp = new KafkaProducer(conf);
        kp.send(new ProducerRecord<String, String>("t01", "he--h22"));
        kp.close();
    }
}

運(yùn)行代碼，沒(méi)報(bào)錯(cuò)，但是在docker中創(chuàng)建的那個(gè)消費(fèi)者也無(wú)法收到消息。

回答

編輯回答

命于你

kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic topic01 --from-beginning

--bootstrap-server localhost:2181 改成Kafka的端口

2017年2月18日 09:40

編輯回答

離觴

首先你要清楚docker容器網(wǎng)絡(luò)機(jī)制，可以去補(bǔ)一補(bǔ)，下面說(shuō)答案：
在啟動(dòng)kafka時(shí)先看一下宿主機(jī)器的ip,使用命令ipconfig查看，
再運(yùn)行zookeeper

docker run -d --name zookeeper -p 2181:2181 zookeeper:latest

再運(yùn)行kafka

docker run -d \
--name kafka \
-p 9092:9092 \
--link zookeeper \
--env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=這里填寫(xiě)ipconfig查看到的宿主ip \
--env KAFKA_ADVERTISED_PORT=9092 \
wurstmeister/kafka:latest

2017年3月21日 14:21