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" ] }'topics数组可以包含一个主题(这里所示)或多个主题。如果要将消费者订阅与正则表达式匹配的多个主题,您可以使用topic_pattern字符串而不是topics数组。如果请求成功,Kafka Bridge 会返回
204(无内容)代码。
使用 Apache Kafka 客户端时,HTTP 订阅操作会将主题添加到本地消费者的订阅中。在运行多个 HTTP 轮询操作后,加入消费者组并获取分区分配,启动分区重新平衡和 join-group 进程。请注意,初始 HTTP 轮询操作可能无法返回任何记录。
接下来要做什么
将 Kafka Bridge 消费者订阅到主题后,您可以从 消费者检索信息。