kafka-rest - 使用 kafka REST 代理响应负载中的自定义响应内容进行响应

Question

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

当前成功响应（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

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