我正在使用Apache Kafka对我的应用程序（用Java编写的REST API）进行基准测试 - 为简单起见，假设有一条消息被发送到Kafka，它会被另一个应用程序回复到另一个主题上 .
在100,000个请求的基准测试中，116个未能将其恢复到我的应用程序 . 但是，在同一主题上使用 kafkacat 作为消费者，收到所有消息之后的偏移量比我开始基准测试之前多了100,000（没有消息丢失） .
有没有关于Kafka Java Consumer API的信息导致它无法接收所有消息？有什么可以做的，还是只是不可避免的？
编辑：
流程：HTTP服务器 - >主题1 - >发送另一条消息的应用程序 - >主题2 - > HTTP服务器