kafka-rest - 使用 kafka REST 代理响应负载中的自定义响应内容进行响应
问题描述
是否可以修改/自定义响应内容?假设我们已经设置了 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"}
解决方案
您可以使用需要编写自己的 REST 扩展 java 类并将它们放在代理的类路径中的属性设置新的端点(和响应) 。kafka.rest.resource.extension.class
但是,如果不分叉项目并修改源代码,则无法修改其他响应
推荐阅读
- go - 填充包含切片的结构
- angular - 使用 angular2 中的 observables 有条件地进行 api 调用
- c3.js - C3折线图中Y轴倒序
- python - GUI 在 cmd 运行时冻结,但不是通过 Pycharm
- html - 为什么网站CSS在浏览器中显示不同
- angular - 如何在有角度动画路由器转换时以角度滚动IntoView?
- neo4j - 如何在 Neo4j 中删除未连接的节点属性
- objective-c - 从 Objective-C 到 Swift 4 的一行代码
- linux - /tmp/sqlite-3.7.2-libsqlitejdbc.so:未定义符号:pthread_mutexattr_init
- java - Google Fit 查询手动启动的活动