"命令 启动 nohup bin/kafka-server-start.sh config/server.properties & 显示 topic bin/kafka-topics.sh --list --zookeeper 172.16.8.28:39181 新建 topic bin/kafka-topics .."

kafka 常用命令

命令

nohup bin/kafka-server-start.sh config/server.properties &

bin/kafka-topics.sh --list --zookeeper 172.16.8.28:39181

bin/kafka-topics.sh --create --zookeeper 172.16.8.28:39181 --replication-factor 1 --partitions 1 --topic SysbacklogFinishTopic

kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic smccheckkafka --zookeeper 10.1.130.84:49181,10.1.130.85:49181,10.1.236.122:49181/kfk

bin/kafka-console-producer.sh --broker-list 172.16.8.28:9092 --topic SysbacklogCreateTopic

bin/kafka-console-consumer.sh --zookeeper 172.16.8.28:39181 --from-beginning --topic KefuCreateTopic

新版本:

bin/kafka-console-consumer.sh --bootstrap-server 172.16.13.121:9092 --from-beginning --topic SysbacklogCreateTopic

bin/kafka-topics.sh --describe --zookeeper 172.16.8.28:39181 --topic SysbacklogCreateTopic

  • Kafka

    Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是现代系统中许多功能的基础。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。

    22 引用 • 34 回帖 • 161 关注
回帖   
请输入回帖内容...