0

是否可以修改/自定义响应内容?假设我们已经设置了 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"}
4

1 回答 1

0

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

于 2021-08-20T12:34:38.510 回答