zoukankan      html  css  js  c++  java
  • kafka配置及其使用

    1:解压
    2:在config中配置server.properties
            broker.id=1
            port=9092
            host.name=Master
            socket.send.buffer.bytes=1048576
            socket.receive.buffer.bytes=1048576
            socket.request.max.bytes=104857600
            log.dir=./kafka-logs
            num.partitions=10
            zookeeper.connect=Master:2181
    3:启动zookeeper:
            在bin下执行:zkServer.sh start
    4:在kafka目录下;
                1):启动kafka服务      bin/kafka-server-start.sh config/server.properties
                 2) :创建主题:   bin/kafka-topics.sh --create --zookeeper Master:2181 --replication-factor 1 --partitions 1 --topic test
                 3): 发送主题:bin/kafka-console-producer.sh --broker-list Master:9092 --topic test
                 4):  接受主题: bin/kafka-console-consumer.sh --zookeeper Master:2181 --topic test --from-beginning
  • 相关阅读:
    linux终端发送邮件
    ubuntu交换Caps 和 ESC
    pycharm快捷键
    python catch socket timeout
    pgsql restart
    python re.sub
    文件写入与缓存
    HTTP协议再分析
    leetcode-45
    Java的锁
  • 原文地址:https://www.cnblogs.com/zqzdong/p/6438966.html
Copyright © 2011-2022 走看看