1.2. AMQ Streams Kafka Bridge

AMQ Streams Kafka Bridge 从技术预览移到 AMQ Streams 的一般组件。

1.2.1. 概述

Kafka Bridge 为 AMQ Streams 提供了一个 RESTful 接口，它提供了 web API 的优点，它可以轻松地与 AMQ Streams 连接，而无需考虑客户端应用程序来解释 Kafka 协议。

Kafka Bridge

API 有两个主要资源 3.10.0-- consumers 和 主题 thats 通过端点公开，可让您与 Kafka 集群中的使用者和制作者进行交互。这些资源仅与 Kafka Bridge 相关，而不与与 Kafka 连接的使用者和制作者相关。

Kafka Bridge 支持 HTTP 请求：

  • 将消息发送到主题。
  • 从主题检索消息。
  • 创建和删除消费者。
  • 将消费者订阅到主题，以便它们开始从这些主题收到信息。
  • 检索消费者订阅的主题列表。
  • 取消订阅消费者的主题。
  • 为消费者分配分区。
  • 提交使用者偏移。
  • 对分区执行 seek 操作。

该方法提供 JSON 响应和 HTTP 响应代码错误处理。可以使用 JSON 或二进制格式发送消息。

请参阅 Kafka Bridge 概述 和 Kafka Bridge 配置。有关 API 文档，请参阅 Kafka Bridge API 参考。

要从本地机器尝试 API，请参阅 Kafka Bridge Quickstart。