kafka

Kafka是一个分布式的消息存储系统,提供了四大核心接口:
1.Producer API允许了应用可以向Kafka中的topics发布消息;
2.Consumer API允许了应用可以订阅Kafka中的topics,并消费消息;
3.Streams API允许应用可以作为消息流的处理者,比如可以从topicA中消费消息,处理的结果发布到topicB中;
4.Connector API提供Kafka与现有的应用或系统适配功能,比如与数据库连接器可以捕获表结构的变化;

Topic —> 每条发布到Kafka集群的消息都有一个类别,这个类别被称为Topic.
Producer —> 负责发布消息到Kafka broker.
Consumer —> 消息消费者,向Kafka broker读取消息的客户端.

Kafka安装:


1
Kafka下载地址:(http://kafka.apache.org/downloads)

版本对应:

Spring for Apache Kafka VersionSpring Integration for Apache Kafka Version
1
kafka-clients
Spring Boot
2.6.0-SNAPSHOT (pre-release)5.4.0-SNAPSHOT (pre-release)2.6.02.4.0-SNAPSHOT (pre-release)
2.5.x3.3.x2.5.02.3.x
2.4.x3.2.x2.4.12.2.x
2.3.x3.2.x2.3.12.2.x
2.2.x3.1.x2.0.1, 2.1.x, 2.2.x2.1.x
ˆ Back To Top