kafka 配置
在kafka config 目录下修改server.properties
broker.id=0
log.dir 修改临时数据存放目录
host.name 当前机器名
zookeeper.connect=hadoop000:2181
启动kafka
先启动zookeeper
kafka-server-start.sh
zk=> kafka-topics.sh --create --zookeeper hadoop000:2181 --replication-factor 1 --partitions 1 --topic testkafka
kafka-topics.sh --list --zookeeper hadoop000:2181
broker=> kafka-console-producer.sh --broker-list localhost:9092 --tpoic testkafka
zk=> kafka-console-consumer.sh --zookeeper hadoop000:2181 --topic testkafka