kafka配置和启动

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

 

kafka配置和启动