kafka相关命令

原创
2016/09/20 16:53
阅读数 135
# 启动zookeeper
./bin/zookeeper-server-start.sh config/zookeeper.properties &
# 启动kafka
./bin/kafka-server-start.sh config/server.properties &


# 后台启动zookeeper
./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 后台启动kafka
./bin/kafka-server-start.sh -daemon config/server.properties


# 创建topic
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

# 创建product
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

# 启动消费者
./bin/kafka-console-consumer.sh --zookeeper hadoop:2181 --topic test

 

展开阅读全文
打赏
0
1 收藏
分享
加载中
更多评论
打赏
0 评论
1 收藏
0
分享
返回顶部
顶部