Ubuntu 单机版Kafka安装

1.下载镜像

1.1 zookeeper安装及启动

1）zookeeper安装

sudo docker pull wurstmeister/zookeeper

2）zookeeper启动

sudo docker run -d --name zookeeper -p 2181 -t wurstmeister/zookeeper

1.2 Kafka安装

1）Kafka安装

sudo docker pull wurstmeister/Kafka

2）Kafka启动

sudo docker run -d --name kafka --publish 9092:9092 \
--link zookeeper \
--env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=127.0.0.1 \
--env KAFKA_ADVERTISED_PORT=9092 --restart=always \
--volume /etc/localtime:/etc/localtime \
wurstmeister/kafka

2.测试发送消息

2.1 进入kafka容器内部

sudo docker exec -i -t ${CONTAINER ID} sh 

${CONTAINER ID}通过docker ps查看
例：

sudo docker exec -i -t 3d23ba2f9ab2 sh

2.2 进入kafka默认目录

cd opt/kafka_2.12-2.1.0

2.3 创建一个主题

bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka

2.4 创建一个生产者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka

2.5 创建一个消费者

重新打开一个tty终端，执行2.1和2.2，进入kafka默认目录

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

2.6 测试

在生产者终端输入消息，在消费者终端查看消息接收。

 

3.基于springboot的demo

SpringBootKafkaDemo.tar.gz