2.5. 将 Kafka Bridge 消费者订阅到主题


创建 Kafka Bridge 使用者后,使用订阅端点 订阅 一个或多个主题。订阅后,消费者开始接收该主题的所有信息。

流程

  • 将消费者订阅之前创建的 bridge-quickstart-topic 主题,在 Produc ing 消息到主题和分区中

    curl -X POST http://localhost:8080/consumers/bridge-quickstart-consumer-group/instances/bridge-quickstart-consumer/subscription \
      -H 'content-type: application/vnd.kafka.v2+json' \
      -d '{
        "topics": [
            "bridge-quickstart-topic"
        ]
    }'
    Copy to Clipboard Toggle word wrap

    topics 数组可以包含一个主题(这里所示)或多个主题。如果要将消费者订阅与正则表达式匹配的多个主题,您可以使用 topic_pattern 字符串而不是 topics 数组。

    如果请求成功,Kafka Bridge 会返回 204 (无内容)代码。

使用 Apache Kafka 客户端时,HTTP 订阅操作会将主题添加到本地消费者的订阅中。在运行多个 HTTP 轮询操作后,加入消费者组并获取分区分配,启动分区重新平衡和 join-group 进程。请注意,初始 HTTP 轮询操作可能无法返回任何记录。

接下来要做什么

将 Kafka Bridge 消费者订阅到主题后,您可以从 消费者检索信息

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat