成都网站建设设计

将想法与焦点和您一起共享

Kafka命令行操作-创新互联

1 主题命令行操作
  1. 查看操作主题命令参数

    创新互联建站专业IDC数据服务器托管提供商,专业提供成都服务器托管,服务器租用,资阳托管服务器资阳托管服务器,成都多线服务器托管等服务器托管服务。
    [azula@hadoop102 kafka]$ bin/kafka-topics.sh
    参数描述
    –bootstrap-server连接的 Kafka Broker 主机名称和端口号。
    –topic操作的 topic 名称。
    –create创建主题。
    –delete删除主题。
    –alter修改主题。
    –list查看所有主题。
    –describe查看主题详细描述。
    –partitions设置分区数。
    –replication-factor设置分区副本。
    –config更新系统默认的配置。
  2. 查看当前服务器中的所有 topic

    [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --list
  3. 创建first topic

    [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create --partitions 1 --replication-factor 3 --topic first

    选项说明:
    –topic 定义topic 名
    –replication-factor 定义副本数
    –partitions 定义分区数

  4. 查看first 主题的详情

    [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first
  5. 修改分区数(注意:分区数只能增加,不能减少

    [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --topic first --partitions 3
  6. 再次查看first 主题的详情

    [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first
  7. 删除topic

    [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --delete --topic first
2 生产者命令行操作
  1. 查看操作生产者命令参数

    [azula@hadoop102 kafka]$ bin/kafka-console-producer.sh
    参数描述
    –bootstrap-server连接的 Kafka Broker 主机名称和端口号。
    –topic操作的 topic 名称。
  2. 发送消息

    [azula@hadoop102 kafka]$ bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first 
    >hello world 
    >azula  azula
3 消费者命令行操作
  1. 查看操作消费者命令参数

    [azula@hadoop102 kafka]$ bin/kafka-console-consumer.sh
    参数描述
    –bootstrap-server连接的 Kafka Broker 主机名称和端口号。
    –topic操作的 topic 名称。
    –from-beginning从头开始消费。
    –group指定消费者组名称。
  2. 消费消息

    • 消费first 主题中的数据。

      [azula@hadoop102 kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first
    • 把主题中所有的数据都读取出来(包括历史数据)。

      [azula@hadoop102 kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning --topic first

你是否还在寻找稳定的海外服务器提供商?创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源,准确流量调度确保服务器高可用性,企业级服务器适合批量采购,新人活动首月15元起,快前往官网查看详情吧


当前名称:Kafka命令行操作-创新互联
文章链接:http://chengdu.cdxwcx.cn/article/gegsg.html