第 5 章 Kafka Bridge 接口
Kafka Bridge 提供了一个 RESTful 接口，它允许基于 HTTP 的客户端与 Kafka 集群交互。 它提供了与 AMQ Streams 的 Web API 连接的优点，而无需客户端应用程序来解释 Kafka 协议。
API 有两个主要资源 - 消费者（consumer）和主题（topic） - 通过端点公开并可访问，以便与 Kafka 集群中的消费者和制作者交互。资源只与 Kafka Bridge 相关，而不是直接连接到 Kafka 的用户和制作者。
5.1. HTTP 请求
Kafka Bridge 支持对 Kafka 集群的 HTTP 请求，使用以下方法：
- 发送消息到主题。
- 从主题检索消息。
- 检索主题的分区列表。
- 创建和删除用户。
- 订阅消费者到主题，以便他们开始从这些主题接收信息。
- 检索消费者订阅的主题列表。
- 取消订阅消费者的主题.
- 为消费者分配分区。
- 提交使用者偏移列表。
- 定位分区，以便消费者开始收到来自第一或最后一个偏移位置的信息，或给定的偏移位置。
该方法提供 JSON 响应和 HTTP 响应代码错误处理。消息可以使用 JSON 或二进制格式发送。
客户端可以在不需要使用原生 Kafka 协议的情况下生成和使用消息。
其他资源
- 要查看 API 文档，包括请求和响应示例，请参阅使用 AMQ Streams Kafka Bridge。
