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
  • 相关阅读:
    BNUOJ 12756 Social Holidaying(二分匹配)
    HDU 1114 Piggy-Bank(完全背包)
    HDU 2844 Coins (多重背包)
    HDU 2602 Bone Collector(01背包)
    HDU 1171 Big Event in HDU(01背包)
    HDU 2571 命运 (入门dp)
    HDU 1069 Monkey and Banana(最长递减子序列)
    HDU 1160 FatMouse's Speed (最长上升子序列)
    HDU 2594 KMP
    POJ 3783 Balls --扔鸡蛋问题 经典DP
  • 原文地址:https://www.cnblogs.com/tonggc1668/p/15246740.html
Copyright © 2011-2022 走看看