我有以下问题：
我收到的消息由生产者产生的延迟（有时长达一分钟）。我对制作人没有控制权，我想确保我这边一切正常。
我在用 kafka-client 版本0.11.0.0。版本更改是可能的，但很乏味，所以我想尽量避免更改版本。
我的消费者配置如下所示：

group.id= unique-group-d
bootstrap.servers = # kafka broker with version 0.11.0.0
auto.offset.reset = latest

# avoid client id collision with Kafka

client.id= some-example-gateway-client

我正在调查这样的信息：

ConsumerRecords<String, String> tConsumerRecords = tempConsumer.poll(1000);
tempMessage.forEach(entry -> {
    [...]
});

与客户端或组id 100%没有名称冲突。我订阅的主题只有一个分区。
我怀疑制作者是在重负下，这是一个独立的环境与零星的消息开始生产的生产者。
今天是星期五，所有人都已经走了，这也于事无补。
我错过什么了吗？我能把责任推给制片人吗？