当前位置：首页 > news >正文

kafka 延迟消费配置

news 2025/11/2 7:07:09

消费者增加配置

增加配置：

ConsumerConfig.DELAYED_TIME_MS_CONFIG，单位为ms

测试验证

消费入口代码如下所示：

    @Overrideprotected void processRecord(ConsumerRecord<String, String> record) {String timestamotype = record.timestampType().toString();long timestamp = record.timestamp();log.info("[SocDlpAlertConsumer] processRecord timestamotype:{}, timestamp:{}", timestamotype, timestamp);String message = record.value();try {socDlpAlertTransferHandler.process(message);} catch (Exception e) {log.error("[SocDlpAlertConsumer]:process message error", e);}}

其中当timestamotype的值为CreateTime时，timestamp的值为生产者生产消息的时间。通过日志打印时间（消费者消费时间）和生产者消息作对比可以查看延迟消费效果。部分日志样例如下所示：

2025-11-01 14:55:04.185 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503448
2025-11-01 14:55:04.186 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503448
2025-11-01 14:55:04.186 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503449
2025-11-01 14:55:04.186 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503449
2025-11-01 14:55:04.186 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503450
2025-11-01 14:55:04.187 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503450
2025-11-01 14:55:04.187 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503451
2025-11-01 14:55:04.187 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503451
2025-11-01 14:55:04.187 ｜ [task-4] | [] | com.manager.kafka.consumer.SocDlpAlertConsumer |  INFO | [SocDlpAlertConsumer] processRecord timestamotype:CreateTime, timestamp:1761979503452

通过时间戳转换，可以看到消费时间和生产时间查10分钟。

查看全文

http://www.dtcms.com/a/556964.html