我正在使用 MaxProcessingTime 为 250 毫秒的 sarama kafka 消费者。当我发送约 400000 字节的大消息时,分区被阻塞,即我的 kafka 消费者停止从该分区读取,并且该分区上的延迟不断增加。这可能是因为 MaxProcessingTime 值吗?
我正在使用 MaxProcessingTime 为 250 毫秒的 sarama kafka 消费者。当我发送约 400000 字节的大消息时,分区被阻塞,即我的 kafka 消费者停止从该分区读取,并且该分区上的延迟不断增加。这可能是因为 MaxProcessingTime 值吗?