Kafka0.8

淡淡的烟草味﹌ 2022-09-20 05:46 40阅读 0赞

启动zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka server

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

创建topic

bin/kafka-create-topic.sh --zookeeper localhost:2181 --replica 1 --partition 1 --topic test

list

bin/kafka-list-topic.sh --zookeeper localhost:2181

producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

comsumer

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

多个brocker 整目录拷贝多份就可以了

cp config/server.properties config/server-1.properties
    cp config/server.properties config/server-1.properties

新的配置

config/server-1.properties:
        broker.id=1
        port=9093
        log.dir=/tmp/kafka-logs-1
    
    config/server-2.properties:
        broker.id=2
        port=9094
        log.dir=/tmp/kafka-logs-2

启动

JMX_PORT=9997 bin/kafka-server-start.sh config/server-1.properties &
    JMX_PORT=9998 bin/kafka-server-start.sh config/server-2.properties &

创建topic

bin/kafka-create-topic.sh --zookeeper localhost:2181 --replica 3 --partition 1 --topic my-replicated-topic

list

bin/kafka-list-topic.sh --zookeeper localhost:2181

publish

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic

comsumer

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic my-replicated-topic

pkill -9 -f server-1.properties
      
       
        
       参考：http://kafka.apache.org/08/quickstart.html

Kafka0.8

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 2020/08/10~08/16周报

相关 2020/08/03~08/09周报

相关 Kafka核心技术与实战 07 08 重要的集群参数配置

相关 08 技术选型：Kafka、RabbitMQ以及RocketMQ

相关 08 ImageButton

相关 Kafka高级特性之零拷贝 08

相关 day08

相关 homework-08

相关【前端】笔试题 2019.08.08

相关 JavaSEDemo08