kafka-docker部署

部署zk

docker pull zookeeper

docker run -d -v /data/zookeeper/zookeeperDataDir:/data -v /data/zookeeper/zookeeperDataLogDir:/datalog  --name zookeeper01 -p 2181:2181 zookeeper

部署kafka

docker pull wurstmeister/kafka

docker run -d --name kafka01 -p 9092:9092 --env KAFKA_ADVERTISED_HOST_NAME=192.168.10.11 -e KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181 wurstmeister/kafka

测试kafka

/opt/kafka/bin:

生产者

bash-4.3# ./kafka-topics.sh --create --zookeeper 192.168.10.11:2181 --replication-factor 1 --partitions 8 --topic test
Created topic "test".
bash-4.3# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test

消费者

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

然后测试一下生产和消费，正常的话，生产这里发，消费者就会收到。