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
  • 相关阅读:
    Centos7更改网卡名为eth0
    Centos7部署Open-Falcon监控
    centos6.x一键15项系统优化(转自努力哥)
    运维题目(十三)
    运维题目(十二)
    Mongodb的学习整理(下)
    Centos7下yum安装mongodb
    浏览器缓存
    控制反转
    js setTimeOut()
  • 原文地址:https://www.cnblogs.com/tonggc1668/p/15246740.html
Copyright © 2011-2022 走看看