第 1 章 开发客户端概述

为 AMQ Streams 安装开发 Kafka 客户端应用程序，它可以生成信息、使用消息或同时这样做。您可以开发在 RHEL 上的 OpenShift 或 AMQ Streams 上使用 AMQ Streams 的客户端应用程序。

消息包含可选键和值，其中包含消息数据以及标头和相关元数据。键标识邮件的主题或消息的属性。如果您需要以与发送相同的顺序处理一组消息，则必须使用相同的密钥。

消息会批量发送。消息包含标头和元数据，用于提供客户端过滤和路由的详情，如消息的时间戳和偏移位置。

Kafka 为开发客户端应用程序提供客户端 API。Kafka 生成者和消费者 API 是与客户端应用程序中的 Kafka 集群交互的主要方法。API 控制消息流。producer API 将信息发送到 Kafka 主题，而使用者 API 从主题读取消息。

AMQ Streams 支持使用 Java 编写的客户端。如何开发您的客户端取决于您的特定用例。数据持久性可能是优先级或高吞吐量。通过配置客户端和代理，可以满足这些要求。但是，所有客户端必须能够连接到给定 Kafka 集群中的所有代理。