• 【kafka】使用docker启动kafka


    1.环境准备

    docker拉取zookeeper镜像

    docker pull zookeeper:3.4.14

    创建zookeeper容器,默认端口号为2181

    docker run -d --name zookeeper -p 2181:2181 zookeeper:3.4.14

    拉取kafka镜像

    docker pull wurstmeister/kafka:2.12-2.3.1

    创键kafka容器,默认端口号为9092

    1. docker run -d --name kafka \
    2. --env KAFKA_ADVERTISED_HOST_NAME=192.168.117.80 \
    3. --env KAFKA_ZOOKEEPER_CONNECT=192.168.117.80:2181 \
    4. --env KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.117.80:9092 \
    5. --env KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
    6. --env KAFKA_HEAP_OPTS="-Xmx256M -Xms256M" \
    7. --net=host wurstmeister/kafka:2.12-2.3.1

    查看是否运行成功

    docker logs -f [进程号]

    2.创建主题

    docker进入kafka容器

    docker exec -it 5af197f9ce2a /bin/bash

    进入bin目录

    首先找到kafka的bin

    find / -name kafka

    cd进去即可

    cd /opt/kafka/bin

    创建topic

    kafka-topics.sh --create --zookeeper 192.168.117.80:2181 --partitions 1 --replication-factor 1 --topic test

    查看topic

    kafka-topics.sh --list --zookeeper 192.168.117.80:2181

    3.创建消息生产者和消费者

    创建生产者

    kafka-console-producer.sh --broker-list 192.168.117.80:9092 --topic test

    创建消息消费者

    从启一个容器实例

    根据项目步骤进入到bin目录

    创建消息消费者

    kafka-console-consumer.sh --bootstrap-server 192.168.117.80:9092 --topic test

    4.测试

    此时是消费最后一个消息后偏移量+1的消息

    若想消费所有消息

    kafka-console-consumer.sh --bootstrap-server 192.168.117.80:9092 --topic test --from-beginning

  • 相关阅读:
    04 后端增删改查【小白入门SpringBoot + Vue3】
    mysql同一个数据值,获取最新的一条数据
    毕业设计选题之Java+springboot线上蔬菜销售与配送系统(源码+调试+开题+lw)
    网络安全第一次作业
    vue页面菜单权限问题解决
    HTB-Tier1
    FastReport4.6 组件安装
    多种编程语言书写hello world
    9月27日复习
    git图形化管理工具
  • 原文地址:https://blog.csdn.net/qq_58137891/article/details/134490376