愚妄

0 声望

这家伙太懒，什么都没留下

个人动态
  • 半兽人 回复 愚妄 在 kafka命令大全 中 ：

    是的。

    4年前
  • 愚妄 回复 愚妄 在 kafka命令大全 中 ：

    这个是最基本的吗？

    4年前
  • 愚妄 回复 半兽人 在 kafka命令大全 中 ：

    在此目录下运行命令
    /opt/kafka_2.12-2.2.0/

    1.启动内置的zookeeper
    bin/zookeeper-server-start.sh config/zookeeper.properties

    2.启动kafka服务
    bin/kafka-server-start.sh config/server.properties

    3.创建topic话题
    bin/kafka-topics.sh --create --topic test --bootstrap-server 192.168.218.128:9092 -partitions 3 -replication-factor 1

    查看所有topic话题
    bin/kafka-topics.sh --list --bootstrap-server 192.168.218.128:9092

    查看指定话题的详情
    bin/kafka-topics.sh --bootstrap-server 192.168.230.128:9092 --describe --topic test

    3.创建生产者
    bin/kafka-console-producer.sh --broker-list 192.168.218.128:9092 --topic test

    4.创建消费者
    bin/kafka-console-consumer.sh --bootstrap-server 192.168.218.128:9092 --topic test

    4年前