搜索

2.2. Kafka 网桥的改进

download PDF

此发行版本包括对 AMQ Streams 的 Kafka Bridge 组件的以下改进。

检索分区和元数据

Kafka Bridge 现在支持以下操作:

  • 检索给定主题的分区列表:

    GET /topics/{topicname}/partitions
  • 检索给定分区的元数据,如分区 ID、领导代理和副本数:

    GET /topics/{topicname}/partitions/{partitionid}

请参阅 Kafka Bridge API 参考

支持 Kafka 消息标头

使用 Kafka Bridge 发送的消息现在可以包括 Kafka 消息标头。

在发送到 /topics 端点 的 POST 请求中,您可以选择在消息有效负载中指定标头,该标头包含在请求正文中。消息标头值必须采用二进制格式,并以 Base64 格式编码。

带有 Kafka 消息标头的请求示例

curl -X POST \
  http://localhost:8080/topics/my-topic \
  -H 'content-type: application/vnd.kafka.json.v2+json' \
  -d '{
    "records": [
        {
            "key": "my-key",
            "value": "sales-lead-0001"
            "partition": 2
            "headers": [
              {
                "key": "key1",
                "value": "QXBhY2hlIEthZmthIGlzIHRoZSBib21iIQ=="
              }
            ]
        },
    ]
}'

请参阅 对 Kafka Bridge 的请求

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.