MoonBox
MoonBox copied to clipboard
请问想流量回放kafka消费逻辑,有没有什么办法
项目主要业务逻辑都在各个kafka的topic消费逻辑代码中,因此想对这部分内容进行流量回放验证。kafka消费代码如下图所示:
依赖包spring-kafka-2.5.7.REALEASE
此外想问一下目前是否支持子调用中发送kafka消息的mock,期望回放时验证子调用入参。
这个可以自行支持下插件。看下其他插件处理逻辑,拦截下这个发送函数