我在用Spring Kafka发消息。当我向Kafka主题发布100条消息时，我可以看到它被Kafka消费者接收，延迟至少1秒，在某些情况下甚至4到5秒。我使用的主题有6个分区，我将消费者的并发性保持在6。
我使用了Kafka消费者的默认属性值。有什么想法可能是错误的，或者我可以调整哪个属性，以最小化延迟到1到2毫秒？我试着发布100，500，1000，5000条消息，但滞后仍然存在。
消费者属性：

• 请求超时ms 30秒
• 心跳间隔毫秒3秒
• 最大轮询间隔（毫秒）5分钟
• 最大轮询记录数200
• 会话超时ms 45秒

消费类

以下是我的消费方法：

@KafkaListener(groupid = AlertsKafkaConfig.GROUP_ID_JSON, topics = TopicNameConstants.Webhook_doc_process_topic_name, containerFacotry = KafkaTopicConstans.WEBHOOK_PROCESS_TOPIC_CONF)
Public void receiveProcessPricessingMessage(@Payload String kafkajsonstring, @Header(KafkaHeaders RECEIVED_TIMESTAMP) String timestamp, @Header(KafkaHeaders.OFFSET) String offset) throws JsonProcessingException {

    try {
        long startime = System.currenttimemillis();
        RequestFactory.appendKafkaId(offset);
        long endtime = System.currenttimemillis();
        Gson gson = new Gson();
        WebhookProcessingCommand eventprocessingcommand = gson.fromJson(kafkajsonstring, WebhookProcessingCommand.class);

        BaseAbstractEventHandler eventprocessinghandler = eventhandlerfactory.getEventhandlerInstance(EventHandler.WEBHOOK_JSON_EVENT_HANDLER.getHandlerName());
        eventprocessinghandler.processEvent(eventprocessingcommand);

    } catch (Exception e) {
        LOGGER.error(ExceptionUtils.fullStackTrace(e));

    }
}