zoukankan      html  css  js  c++  java
  • run kafka local

    Q: How to run kafka local
    download kafka http://kafka.apache.org/downloads

    start zookeeper
    $ bin/zookeeper-server-start.sh config/zookeeper.properties
    start kafka
    $ bin/kafka-server-start.sh config/server.properties
    or JMX_PORT=9988 bin/kafka-server-start.sh -daemon config/server.properties
    start kafka producer
    $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topicName
    start kafka consumer
    $ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning --consumer-property group.id=test-group
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning --consumer-property group.id=test-group --isolation-level read_committed
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --consumer-property group.id=test-group
    cat kafka-consumer-groups
    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
    describe kafka-consumer-group
    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-group
    describe topic
    bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topicName
    delete topic
    bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic topicName
    create topic
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic topicName
  • 相关阅读:
    js 屏蔽 键盘 按键
    什么情况下HttpContext.Current.Request.UrlReferrer为空
    vm下linux 按钮 vmware tools
    Table td中 div 不能100%的原因
    行转列
    office 2010 ;密钥
    HTTP 错误 500.21
    [Servlet3.0新特性]Servlet异步处理
    [Servlet3.0新特性]Serlvet文件上传
    [Servlet3.0新特性]注解替代配置文件
  • 原文地址:https://www.cnblogs.com/tonggc1668/p/15246740.html
Copyright © 2011-2022 走看看