创建Topic
创新互联坚持“要么做到，要么别承诺”的工作理念，服务领域包括：
网站设计、成都网站制作、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的
尖山网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic abtest --partitions 2 --replication-factor 1
查看Topic都有哪些
kafka-topics.sh --list --zookeeper localhost:2181
生产者，将文件中的数据写入Kafka生产者
kafka-console-producer.sh --broker-list localhost:9092 --topic order_topic < abc.txt
消费者，从最开始的位移，消费Topic中的数据
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic order_topic --from-beginning
重置Consumer Group的Offset到最新位移
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group_name_1 --reset-offsets --topic order_topic --to-latest --execute
查看消费者组Consumer Group位移
[homework@test ~]$ kafka-consumer-groups.sh --bootstrap-server host1:9092,host2:9092 --describe --group groupname_1
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
order 5 20781271 20781556 285 - - -
order 1 10553765 10554032 267 - - -
order 2 10634508 10634808 300 - - -
order 7 10375128 10375355 227 - - -
order 6 10435147 10435467 320 - - -
order 0 10640342 10640643 301 - - -
order 3 13762141 13762478 337 - - -
order 8 11176468 11176707 239 - - -
order 4 10443088 10443320 232 - - -
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
网站名称：【Kafka】常用命令-创新互联
文章地址：
http://cdkjz.cn/article/cspjhg.html
