网上销售 网站建设,金湖县住房和城乡建设局网站,网站设计和制作费用,网站推广方案有哪些主题命令行操作 1#xff09;查看操作主题命令参数 [ubuntuhadoop kafka]$ bin/kafka-topics.sh
参数描述--bootstrap-server连接的KafkaBroker主机名称和端口号。--topic操作的topic名称。--create创建主题。--delete删除主题。--alter修改主题。--list查看所有主题。--desc… 主题命令行操作 1查看操作主题命令参数 [ubuntuhadoop kafka]$ bin/kafka-topics.sh
参数描述--bootstrap-server连接的KafkaBroker主机名称和端口号。--topic操作的topic名称。--create创建主题。--delete删除主题。--alter修改主题。--list查看所有主题。--describe查看主题详细描述。--partitions设置分区数。--replication-factor设置分区副本。--config更新系统默认的配置。
2查看当前服务器中的所有 topic [ubuntuhadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --list
3创建 first topic [ubuntuhadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --create --partitions 1 --replication-factor 3 --topic first
4查看 first 主题的详情 [ubuntuhadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --describe --topic first
5修改分区数注意分区数只能增加不能减少 [ubuntuhadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --alter --topic first --partitions 3
6再次查看 first 主题的详情 [ubuntuhadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --describe --topic first
7删除 topic学生自己演示 [ubuntuhadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --delete --topic first
生产者命令行操作
1查看操作生产者命令参数 [ubuntuhadoop kafka]$ bin/kafka-console-producer.sh
参数描述--bootstrap-server连接的 Kafka Broker 主机名称和端口号。--topic操作的 topic 名称。
2发送消息 [ubuntuhadoop kafka]$ bin/kafka-console-producer.sh --bootstrap-server hadoop:9092 --topic first hello world
消费者命令行操作
1查看操作消费者命令参数 [ubuntuhadoop kafka]$ bin/kafka-console-consumer.sh
参数描述--bootstrap-server连接的 Kafka Broker 主机名称和端口号。--topic操作的 topic 名称。--from-beginning从头开始消费。--group指定消费者组名称。
2消费消息
1消费first主题中的数据。 [ubuntuhadoop kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop:9092 --topic first
2把主题中所有的数据都读取出来包括历史数据。 [ubuntuhadoop kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop:9092 --from-beginning --topic first
