[incubator-iotdb] branch master updated: [IOTDB-785] Disable anonymous access MQTT service (#1447)

[qi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 305fa47  [IOTDB-785] Disable anonymous access MQTT service (#1447)
305fa47 is described below

commit 305fa47200f0c4c4fbb42ff0be6333ed753b5bed
Author: Xin Wang <xi...@apache.org>
AuthorDate: Thu Jul 2 08:57:57 2020 +0800

    [IOTDB-785] Disable anonymous access MQTT service (#1447)
    
    * [IOTDB-503] Add checkTimeseriesExists for session
    * [IOTDB-785] Disable anonymous access MQTT service
---
 server/src/main/java/org/apache/iotdb/db/service/MQTTService.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java b/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
index 5118b63..84ce477 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
@@ -77,6 +77,8 @@ public class MQTTService implements IService {
         properties.setProperty(BrokerConstants.PORT_PROPERTY_NAME, String.valueOf(iotDBConfig.getMqttPort()));
         properties.setProperty(BrokerConstants.BROKER_INTERCEPTOR_THREAD_POOL_SIZE, String.valueOf(iotDBConfig.getMqttHandlerPoolSize()));
         properties.setProperty(BrokerConstants.IMMEDIATE_BUFFER_FLUSH_PROPERTY_NAME, "true");
+        properties.setProperty(BrokerConstants.ALLOW_ANONYMOUS_PROPERTY_NAME, "false");
+        properties.setProperty(BrokerConstants.ALLOW_ZERO_BYTE_CLIENT_ID_PROPERTY_NAME, "true");
         properties.setProperty(BrokerConstants.NETTY_MAX_BYTES_PROPERTY_NAME, String.valueOf(iotDBConfig.getMqttMaxMessageSize()));
         return new MemoryConfig(properties);
     }