Kafka-2.11学习笔记（二）Shell脚本介绍

lanying56123

# 消息生产者　　
[hadoop@nnode kafka0.8.2.1]$ bin/kafka-console-producer.sh
　　
Read data from standard input and publish it to Kafka. # 从控制台读取数据
　　
Option                             Description
　　
------                             -----------
　　
--topic                     REQUIRED: The broker list string in the form HOST1:PORT1,HOST2:PORT2.
　　
--broker-list         REQUIRED: The topic id to produce messages to.
　　
    # 这两个为必选参数，其他的可选参数可以通过直接执行该命令查看帮助
　　

　　
# 消息消费者
　　
[hadoop@nnode kafka0.8.2.1]$ bin/kafka-console-consumer.sh
　　
The console consumer is a tool that reads data from Kafka and outputs it to standard output.
　　
Option                             Description
　　
------                             -----------
　　
--zookeeper                  REQUIRED: The connection string for the zookeeper connection，
　　
                                   in the form host:port.（Multiple URLS can be given to allow fail-over.）
　　
--topic                     The topic id to consume on.
　　
--from-beginning                   If the consumer does not already have an established offset to
　　
                                   consume from, start with the earliest message present in the
　　
                                   log rather than the latest message.
　　
    # zookeeper参数是必须的，其他的都是可选的，具体的参考帮助信息
　　

　　
# 查看消息信息
　　
[hadoop@nnode kafka0.8.2.1]$ bin/kafka-topics.sh
　　
Create, delete, describe, or change a topic.
　　
Option                             Description
　　
------                             -----------
　　
--zookeeper                  REQUIRED: The connection string for the zookeeper connection,
　　
                                   in the form host:port. （Multiple URLS can be given to allow fail-over.）
　　
--create                           Create a new topic.
　　
--delete                           Delete a topic
　　
--alter                            Alter the configuration for the topic.
　　
--list                             List all available topics.
　　
--describe                         List details for the given topics.
　　
--topic                     The topic to be create, alter or describe. Can also accept
　　
                                   a regular expression except for --create option。
　　
--help                             Print usage information.
　　
    # zookeeper参数是必须的，其他的都是可选的，具体的参考帮助信息