1.2. Kafka Bridge 接口
Kafka Bridge 提供了一个 RESTful 接口,允许基于 HTTP 的客户端与 Kafka 集群交互。 它提供与 AMQ Streams 的 Web API 连接的优点,而无需客户端应用程序来解释 Kafka 协议。
API 有两个主要资源( 使用者 和主题 ),它们可以通过端点公开并可访问,以便与 Kafka 集群中的消费者和制作者交互。这些资源仅与 Kafka Bridge 相关,而不与与 Kafka 连接的使用者和制作者相关。
1.2.1. HTTP 请求 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Kafka Bridge 支持到 Kafka 集群的 HTTP 请求,其方法如下:
- 发送消息到主题。
- 从主题检索消息。
- 检索主题的分区列表。
- 创建和删除消费者。
- 将消费者订阅到主题,以便它们开始从这些主题收到信息。
- 检索消费者订阅的主题列表。
- 取消订阅消费者的主题。
- 为消费者分配分区。
- 提交使用者偏移列表。
- 寻求分区,以便消费者开始从第一或最后一个偏移位置收到信息,或给定的偏移位置。
该方法提供 JSON 响应和 HTTP 响应代码错误处理。可以使用 JSON 或二进制格式发送消息。
客户端可以在不需要使用原生 Kafka 协议的情况下生成和使用消息。