命令

  • 启动

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

    17 引用 • 28 回帖 • 185 关注
感谢    关注    收藏    赞同    反对    举报    分享