Kafka Rest Proxy能否自定义响应payload以隐藏敏感信息？

完全支持自定义修改或拦截Kafka Rest Proxy的响应内容，可根据你的实际场景选择以下三种落地方式：

• 方案1：扩展内置拦截器实现（改造成本最低）
  Kafka Rest Proxy 开放了ProducerInterceptor扩展接口，你可以自行实现自定义拦截器，在消息生产成功、返回默认响应之前拦截响应结构体，过滤掉partition、offset、schema_id等敏感字段，直接组装成你需要的{"success": "Record received/processed successfully"}简化结构返回即可，无需修改服务核心源码。

• 方案2：反向代理层重写响应（无侵入）
  如果你不想改动已上线的Kafka Rest Proxy服务，可以在服务前部署一层Nginx、APISIX等反向代理，配置响应重写规则：匹配到生产消息接口、且状态码为200时，直接将响应体替换为你预设的简化结构即可，原有服务逻辑完全不用调整。

• 方案3：修改源码自定义响应逻辑（适配复杂需求）
  如果后续还有更多响应自定义需求，可以拉取对应版本的Kafka Rest Proxy开源源码，找到生产消息成功后的响应组装逻辑，直接修改返回结构后重新编译部署即可。

额外提示：无论选择哪种方案，都要做好异常场景的响应兼容，消息生产失败的场景建议保留错误码和错误描述返回，避免影响调用方排查问题。

内容的提问来源于stack exchange，提问作者Vijayt00