Kafka实战


  • 简介
  • 目录大纲
  • 最新文档

    29、Kafka:Docker-compose部署Kafka集群

    Docker-compose部署Kafka集群 删除Docker ```python 停止所有容器 docker stop $(docker ps -a -q) 删除所有容器 docker rm $(docker ps -aq) 删除所有镜像 docker rmi -f $(docker images -qa) 删除旧Docker sudo yum remove docker \ ……

    李智 - 2025年3月17日 13:29


    28、Kafka:Linux部署Kafka集群

    准备 准备三台虚拟机,IP地址分别为: ```python 192.168.217.151 192.168.217.152 192.168.217.153 ``` 下载Jdk,Zookeeper和Kafka压缩包 下载地址:https://download.csdn.net/download/weixin_41405524/87515680 上传压缩包到服务器 将压缩包分别上传到三台Kafka服……

    李智 - 2025年3月17日 13:29


    27、Kafka:Kafka-eagle监控平台

    Kafka-eagle监控平台 搭建 - 去kafka-eagle官⽹下载压缩包http://download.kafka-eagle.org/ 分配⼀台虚拟机 虚拟机中安装jdk 解压缩kafka-eagle的压缩包 给kafka-eagle配置环境变量 ```python export KE_HOME=/usr/local/kafka-eagle export PATH=$PATH:$K……

    李智 - 2025年3月17日 13:29


    26、Kafka:Kafka优化之实现延时队列

    Kafka优化之实现延时队列 应⽤场景 订单创建后,超过30分钟没有⽀付,则需要取消订单,这种场景可以通过延时队列来实现 具体方案 kafka中创建相应的主题 消费者消费该主题的消息(轮询) 消费者消费消息时判断消息的创建时间和当前时间是否超过30分钟(前提是订单没⽀付) 如果是:去数据库中修改订单状态为已取消 如果否:记录当前消息的offset,并不再继续消费之后的消息。等……

    李智 - 2025年3月17日 13:29


    25、Kafka:Kafka优化之解决消息积压问题

    Kafka优化之解决消息积压问题 消费者消费能力过弱 消息积压问题的出现 消息的消费者的消费速度远赶不上⽣产者的⽣产消息的速度,导致kafka中有⼤量的数据没有被消费。随着没有被消费的数据堆积越多,消费者寻址的性能会越来越差,最后导致整个kafka对外提供的服务的性能很差,从⽽造成其他服务也访问速度变慢,造成服务雪崩。 消息积压的解决方案 在这个消费者中,使⽤多线程,充分利⽤机器的性能进⾏消费……

    李智 - 2025年3月17日 13:29



    李智