From a31a452b9999ba3c811c36b5cb1b3ec0c18d037d Mon Sep 17 00:00:00 2001 From: jiazx0107@163.com <jiazx0107@163.com> Date: 星期三, 08 十一月 2023 02:23:38 +0800 Subject: [PATCH] 提交MQTT相关功能 --- src/main/resources/application-devGateway.yml | 31 +++++++++++++++++++------------ 1 files changed, 19 insertions(+), 12 deletions(-) diff --git a/src/main/resources/application-devGateway.yml b/src/main/resources/application-devGateway.yml index e6029e2..09d7b84 100644 --- a/src/main/resources/application-devGateway.yml +++ b/src/main/resources/application-devGateway.yml @@ -48,8 +48,15 @@ timeout: 6000 kafka: bootstrap-servers: 103.203.217.16:9092 + producer: + retries: 0 + acks: 1 + batch-size: 16384 + buffer-memory: 33554432 + key-serializer: org.apache.kafka.common.serialization.StringSerializer + value-serializer: org.apache.kafka.common.serialization.StringSerializer properties: - security.protocol: sasl_plaintext + security.protocol: SASL_PLAINTEXT sasl.mechanism: PLAIN sasl.username: sc001 sasl.password: wCV0ISwmoKwbx1lpBKMW @@ -62,14 +69,14 @@ key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer -mqtt: - host: tcp://10.13.4.84:11883 - client-id: - client-username: - client-password: - client-timeout: 10 - client-alive-time: 20 - client-max-connect-times: 5 - client-topics: - client-qos: 0 - isOpen: false + mqtt: + host: tcp://10.13.4.84:11883 + client-id: + client-username: admin + client-password: 123456 + client-timeout: 10 + client-alive-time: 20 + client-max-connect-times: 5 + client-topics: "/device/${productId}/${deviceId}/message/property/report,/device-message-sender/${productId}/${deviceId}" + client-qos: 0 + isOpen: false -- Gitblit v1.9.3