# Linux操作kafka
我的集群是使用CDH安装的，所以安装Kafka就很简单，使用CDH提供的页面，下一步、下一步就可以完成安装
由于是CDH安装的，启动的脚本目录为： /opt/cloudera/parcels/CDH/lib/kafka
cd /opt/cloudera/parcels/CDH/lib/kafka
1
# 查看创建的topic
bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181
1
# 创建topic
bin/kafka-topics.sh --create --zookeeper node1:2181,node2:2181,node3:2181 --replication-factor 3 --partitions 3 --topic test_sensen
1
- replication-factor：副本数
- partitions：分区数
- topic：话题
# 创建topic生产者
bin/kafka-console-producer.sh --broker-list node1:9092,node2:9092,node3:9092 --topic test_sensen
1
# 创建topic消费者
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --topic test_sensen --from-beginning
1
# 注意
如果在创建kafka时有以下配置
则在创建topic时命令修改为如下：
bin/kafka-topics.sh --create --zookeeper node1:2181,node2:2181,node3:2181/kafka --replication-factor 3 --partitions 3 --topic test_sensen
1
查询命令为：
bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181
1