我有一套使用嵌入式Kafka库的测试。
它们运行一个拓扑（一个复杂的拓扑，有几个状态存储和会话窗口）。这些测试使用输出主题来确保生成的数据是正确的。
因为它是一个嵌入式服务（而不是topologytestdriver，我也在其他测试中使用它，并且没有这些问题），所以它们需要一定的延迟来等待拓扑生成数据（即使用存储，以及从中读取其他主题，等），然后在完成数据检查之前最终进入主题。
然而，当从Kafka2.3升级到2.5时，我的一些测试失败了，因为数据到达主题需要更长的时间。因此，增加这些延迟将使拓扑有时间
Kafka2.3和2.5版本之间的哪些变化可能会影响到这一点？我浏览了升级评论，看不出什么是罪魁祸首。
除此之外，我可以使用哪些设置来控制生成和读取这些消息的速度，并帮助拓扑更快地运行？我试过了 commit.interval.ms 但这没有帮助。