安装kafka注意事项
修改 、vim kafka/config/server.properties
三个地方①brokerId ②logs=地址③指定节点
一、创建主题
（必须指定分区，指定副本）
#在kafka bin目录下执行以下命令
#①连接hadoop01 创建主题为TEST 分区1 副本3个
bin/kafka-topics.sh --bootstrap-server hadoop01:9092 --topic TEST --create --partitions 1 --replication-factor 3查看创建的主题
#查看Hadoop01节点所有主题
bin/kafka-topics.sh --boostrap-server hadoop01:9092 --list
#查看主题为TEST的详情
bin/kakfa-topics.sh --boostrap-server hadoop01:9092 TEST --describe
二、生产者
给指定主题发消息
bin/kakfa-console-producer.sh --bootstrap-server hadoop01:9092 --topic TEST查看数据
三、消费者
#从最开头消费
bin/kafka-console-consumer.sh --bootstrap-server hadoop01:9092 --topic TEST --from-beginning
