2.2. Kafka 网桥的改进
此发行版本包括对 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 网桥的请求。