From 58c42fa9ee6583aa4dffba6cef3c5cdcf9c811be Mon Sep 17 00:00:00 2001 From: mahaotian's debian Date: Sun, 22 Sep 2024 16:04:05 +0800 Subject: [PATCH] [INLONG-11175][Agent] Fix the problem of mqttsource message loss --- .../java/org/apache/inlong/agent/plugin/sources/MqttSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java index 144a1e6cc4..8ace035b7a 100644 --- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java +++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java @@ -115,7 +115,7 @@ public void messageArrived(String topic, MqttMessage message) throws Exception { headerMap.put("record.messageId", String.valueOf(message.getId())); headerMap.put("record.qos", String.valueOf(message.getQos())); byte[] recordValue = message.getPayload(); - mqttMessagesQueue.offer(new DefaultMessage(recordValue, headerMap), 1, TimeUnit.SECONDS); + mqttMessagesQueue.offer(new DefaultMessage(recordValue, headerMap)); }