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 Version | Spring Integration for Apache Kafka Version |
| Spring Boot | ||
2.6.0-SNAPSHOT (pre-release) | 5.4.0-SNAPSHOT (pre-release) | 2.6.0 | 2.4.0-SNAPSHOT (pre-release) | ||
2.5.x | 3.3.x | 2.5.0 | 2.3.x | ||
2.4.x | 3.2.x | 2.4.1 | 2.2.x | ||
2.3.x | 3.2.x | 2.3.1 | 2.2.x | ||
2.2.x | 3.1.x | 2.0.1, 2.1.x, 2.2.x | 2.1.x |