zoukankan      html  css  js  c++  java
  • kafka常见命令

    一、启动kafka 集群

      

    bin/kafka-server-start.sh config/server.properties &

    二、创建一个Kafka的topic-----(localhost:2181指的是zk主机)

    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic

    三、查看创建分区的详细信息,即(but now that we have a cluster how can we know which broker is doing what? To see that run the "describe topics" command)

    bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic

    Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:
        Topic: my-replicated-topic  Partition: 0    Leader: 1   Replicas: 1,2,0 Isr: 1,2,0

    解释:“leader”是负责给定分区的所有读写的节点。每个节点将是分区的随机选择部分的领导者。             

         “Replicas”是复制这个分区日志的节点列表,不管它们是领导者还是活的。             

         “Isr”是一组“同步”复制品。这是当前活着并复制到领导者的复制列表的子集。

    四、关于这个topic,启动一个生产者进程(结束进程的方式:ctrl+c)

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic
    ...
    my test message 1//发送的信息
    my test message 2

    五、关于这个topic,启动一个消费者进程(另外开启一个连接窗口)//(结束进程的方式:ctrl+c)

    > bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic
    ...
    my test message 1
    my test message 2

    六、关于容错性的测试(对于处于leader的kafka)-----待验证

    > ps aux | grep server-1.properties
    root     38660  0.0  0.0 112660   980 pts/4    S+   20:13   0:00 grep --color=auto server-3.properties> kill -9 7564

     七、使用kafka导入/导出数据

  • 相关阅读:
    css选择器解析规则
    swiper轮播图包含视频或图片
    css实现文字选中变色
    swiper鼠标滚轮事件
    C语言中,关于相除的问题
    输入测试字符型数据的组数,再输入字符型数据,排坑
    C语言中,字符型数字与常数型数字的加减实现
    C语言的指针用法:输入一堆字符,把非字母的删去。
    C语言中倒序输出你输入的数。
    C语言中,嵌套的if语句的一些经验...
  • 原文地址:https://www.cnblogs.com/ljangle/p/8886166.html
Copyright © 2011-2022 走看看