SpringBoot 整合 Kafka

环境ZooKeeper、Kafka。如果使用 docker-compose 部署 Kafka 集群，可以参考我的这篇文章 docker-compose安装Kafka集群依赖pom.xml 依赖文件如下：springboot 版本是 2.3.0.RELEASE 。<dependencies>

查看全文

Kafka概览

KafkaKafka 是一种高吞吐量、分布式、基于发布/订阅的消息系统，最初由 LinkedIn 公司开发，使用Scala 语言编写，目前是 Apache 的开源项目。Kafka 中的概念及其含义：broker： Kafka 服务器，负责消息存储和转发topic：消息类别， Kafka 按照 top

查看全文

docker-compose安装Kafka集群

前提由于 Kafka 借助 ZooKeeper 进行数据同步，所以安装 Kafka 集群时，需先安装 ZooKeeper 集群。为了降低耦合，分别安装 ZooKeeper 集群和 Kafka 集群，然后通过配置在同一个 Docker 网络中保证 Kafka 能和 ZooKeeper 正常通信。首先通

查看全文