arex-agent-java
arex-agent-java copied to clipboard
请问想流量回放kafka消费逻辑,有没有什么办法
项目主要业务逻辑都在各个kafka的topic消费逻辑代码中,因此想对这部分内容进行流量回放验证。kafka消费代码如下图所示:
依赖包spring-kafka-2.5.7.REALEASE
此外想问一下目前是否支持子调用中发送kafka消息的mock,期望回放时验证子调用入参。
@yihancheng 有办法的,需要看看 @KafkaListener
这个注解的处理过程,另外针对回放过程需要确认是否支持指定机器消息消息