zoukankan      html  css  js  c++  java
  • Kafka—命令行操作

    1.查看当前服务器中的所有topic

    [ck@hadoop102 kafka_2.12-2.6.1]$ bin/kafka-topics.sh  -- zookeeper hadoop102:2181 -- list

    2.创建topic

    [ck@hadoop102 kafka_2.12-2.6.1]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --create --replication-factor 3 --partitions 1 --topic first
    
    Created topic first.

    选项说明:

    –topic 定义topic名

    –replication-factor  定义副本数

    –partitions  定义分区数

    3.删除topic

    [ck@hadoop102 kafka_2.12-2.6.1]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --delete --topic first

    需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

    4.发送消息

    [ck@hadoop102 kafka_2.12-2.6.1]$ bin/kafka-console-producer.sh --broker-list hadoop102:9092 --topic first 

    >hello world
    >ck ck

     

    5.消费消息

    [ck@hadoop103 kafka_2.12-2.6.1]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first

    –from-beginning:会把first主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。

    6.查看某个Topic的详情

    [ck@hadoop102 kafka_2.12-2.6.1]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --describe --topic first
    Topic: first    PartitionCount: 1       ReplicationFactor: 3    Configs: 
            Topic: first    Partition: 0    Leader: 0       Replicas: 0,1,2 Isr: 0,1

    整理至atguigu视频

  • 相关阅读:
    Path Sum
    Intersection of Two Linked Lists (求两个单链表的相交结点)
    Nginx入门资料
    赛马问题
    翻转单词顺序 VS 左旋转字符串
    重建二叉树
    Fibonacci相关问题
    Find Minimum in Rotated Sorted Array(旋转数组的最小数字)
    常用查找算法总结
    Contains Duplicate
  • 原文地址:https://www.cnblogs.com/zs-chenkang/p/14431511.html
Copyright © 2011-2022 走看看