《Kafka in Action》Dylan Scott.Viktor Gamov.Dave Klein.2022 by Manning Publications Co. All rights reserved.
本章涵盖:
1、 Kafka high-level的体系结构
2、 理解客户端选项
3、 程序是如何与broker通信
4、生产和消费第一条消息
5、在java程序中使用kafka客户端
2.1 生产和消费消息
一般每个消息都有一个时间戳、消息体和一个可选key。如果需要也可以自定义头部[1]。消息的一个简单示例如下所示:在“2020-10-02T10:34:11.654Z”(消息时间戳),主机ID为“1234567”(消息的key)发出了告警信息:“警报:设备故障”(消息体)。第9章将演示使用自定义头设置键值对来跟踪的用例。
图2.1显示了用户直接处理的消息中最重要和最常见的部分。key和消息体将是本章大篇幅讨论的重点,每个key和值都可以以特定的方式序列化或反序列化数据后进行通信。如何使用序列化的信息的细节将在第4章展示。
image.png
上图我们可以看到key并不是必须的。
网友评论