在 kafka rest 代理响应负载中响应自定义响应内容

Question

是否可以modify/customize回复内容？假设我们设置了 kafka rest 代理来接收来自外部服务的数据，并且我们不想泄露敏感信息，比如存储在哪个分区和偏移量数据中。我们只想回复记录 processed/received（或未处理）。

当前成功响应(for 200)

  { "offsets": [{
                        "partition": 1,
                        "offset": 1,
                        "error_code": null,
                        "error": null
                }],
                "key_schema_id": null,
                "value_schema_id": null
   }

上面的响应可以自定义或截取为下面的响应吗？

     {"success": "Record received/processed successfully"}

Answer 1

您可以使用 kafka.rest.resource.extension.class 属性设置 新端点（和响应），这需要编写您自己的 REST 扩展 java 类并将它们放在代理的类路径中。但是，在不fork项目和修改源代码的情况下，是无法修改其他响应的

在 kafka rest 代理响应负载中响应自定义响应内容

Responding with custom response content in kafka rest proxy response payload

kafka-rest

confluent-rest-proxy