请问想流量回放kafka消费逻辑，有没有什么办法

项目主要业务逻辑都在各个kafka的topic消费逻辑代码中，因此想对这部分内容进行流量回放验证。kafka消费代码如下图所示：
依赖包spring-kafka-2.5.7.REALEASE

此外想问一下目前是否支持子调用中发送kafka消息的mock，期望回放时验证子调用入参。

The issue provides screenshots of Kafka consumer code and names the spring-kafka-2.5.7.REALEASE dependency, but no files or tests. Start by locating the shown consumer logic and reviewing how traffic replay currently handles Kafka. Clarify whether replaying consumed traffic and mocking Kafka messages sent by child calls are separate requirements; done should be defined by concrete supported behavior and validation cases.

Written by the indexing model from the issue text.