docker安装kafka及使用

### 1、下载镜像

docker pull wurstmeister/zookeeper
	docker pull wurstmeister/kafka

### 2、先启动zookeeper
单机方式

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

### 3、启动kafka

docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=localhost:2181 --env KAFKA_ADVERTISED_HOST_NAME=127.0.0.1 --env KAFKA_ADVERTISED_PORT=9092 wurstmeister/kafka

localhost为本机ip

### 4、创建一个topic

#进入容器
	docker exec -it ${CONTAINER ID} /bin/bash
	cd opt/bin
	#单机方式：创建一个主题
	bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka
	#运行一个生产者
	bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
	>Hello Kafka!
	>你好 kafka!
	#运行一个消费者（版本不一样选择不同）
	bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning
	或
	bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic mykafka --from-beginning

### 5、kafka设置分区数量

#分区数量的作用：有多少分区就能负载多少个消费者，生产者会自动分配给分区数据，每个消费者只消费自己分区的数据，每个分区有自己独立的offset
	#进入kafka容器
	vi opt/kafka/config/server.properties
	修改run.partitions=2
	#退出容器
	ctrl+p+q
	#重启容器
	docker restart kafka

#修改指定topic
	./kafka-topics.sh --zookeeper localhost:2181 --alter --partitions 3 --topic topicname
	
	
### 	6、客户端下载地址
	
	http://www.kafkatool.com/download.html
	
7、查看kafka版本号

首先进入容器，执行命令
（1）第一种

bash-5.1# find / -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'
	kafka_2.13-2.8.1
（2）第二种

bash-5.1# cd /opt/
	bash-5.1# ls
	kafka             kafka_2.13-2.8.1  overrides