本文介绍: Kafka —— 消息生产者(演示 发送消息) 和 消息消费者(演示 监听消息)
Kafka — 消息生产者
★ 消息
简单来说,就是一个数据项。
▲ 消息就是 Kafka 所记录的数据节点,消息在 Kafka 中又被称为记录(record)或事件(event)。
从存储上来看,消息就是存储在分区文件(有点类似于List)中的一个数据项,消息具有 key、value、时间戳 和 可选的元数据头。
▲ 下面是一个示例事件:
key: “fkjava”
value: “publish a new Book”
timestamp: “Feb. 15, 2021 at 2:06 p.m.”
★ 消息的分发机制
★ 分发到哪个分区
★ 轮询策略(round-robin)
★ 使用命令行工具发送消息
演示添加消息
Kafka — 消息消费者
★ 消息消费者命令
▲ 监听 【指定主题】 的所有消息:
▲ 监听 【指定主题、指定分区】的所有消息:
▲ 监听【指定主题、指定分区】的【新】消息:
▲ 监听【指定主题、指定分区的、指定下标及之后】的所有消息:
kafka灵活之处:
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。