2021-05-31 10:24:42.013[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 10:24:42.071[INFO] [main] - logLevel = INFO 2021-05-31 10:24:42.071[INFO] [main] - PRE = mqtt.broker. 2021-05-31 10:24:42.072[INFO] [main] - version = 1.0.0 2021-05-31 10:24:42.072[INFO] [main] - anonymousEnable = true 2021-05-31 10:24:42.073[INFO] [main] - pollThreadNum = 16 2021-05-31 10:24:42.073[INFO] [main] - maxPollEventNum = 10 2021-05-31 10:24:42.074[INFO] [main] - pollWaitInterval = 10 2021-05-31 10:24:42.074[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 10:24:42.074[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 10:24:42.080[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 10:24:42.081[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 10:24:42.081[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 10:24:42.081[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 10:24:42.082[INFO] [main] - redisPort = 6379 2021-05-31 10:24:42.082[INFO] [main] - pool = false 2021-05-31 10:24:42.082[INFO] [main] - redisDb = 2 2021-05-31 10:24:42.082[INFO] [main] - redisPassword = 2021-05-31 10:24:42.082[INFO] [main] - maxWaitMills = 60000 2021-05-31 10:24:42.083[INFO] [main] - testOnBorrow = true 2021-05-31 10:24:42.083[INFO] [main] - minIdle = 20 2021-05-31 10:24:42.084[INFO] [main] - maxTotal = 200 2021-05-31 10:24:42.084[INFO] [main] - maxIdle = 50 2021-05-31 10:24:42.085[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 10:24:42.085[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 10:24:42.085[INFO] [main] - username = root 2021-05-31 10:24:42.085[INFO] [main] - password = 12345678 2021-05-31 10:24:42.086[INFO] [main] - highPerformance = false 2021-05-31 10:24:42.086[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 10:24:42.087[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 10:24:42.087[INFO] [main] - kafkaAcks = -1 2021-05-31 10:24:42.088[INFO] [main] - kafkaRetries = 3 2021-05-31 10:24:42.088[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 10:24:42.089[INFO] [main] - kafkaLingerMs = 1 2021-05-31 10:24:42.089[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 10:24:42.090[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 10:24:42.090[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 10:24:42.090[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 10:24:42.090[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 10:24:42.090[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 10:24:42.091[INFO] [main] - pollDuration = 200 2021-05-31 10:24:42.091[INFO] [main] - clientId = test 2021-05-31 10:24:42.091[INFO] [main] - groupId = group_test 2021-05-31 10:24:42.091[INFO] [main] - autoCommit = true 2021-05-31 10:24:42.091[INFO] [main] - autoCommitInterval = 100 2021-05-31 10:24:42.092[INFO] [main] - tcpBackLog = 1024 2021-05-31 10:24:42.092[INFO] [main] - tcpNoDelay = false 2021-05-31 10:24:42.092[INFO] [main] - tcpReuseAddr = true 2021-05-31 10:24:42.092[INFO] [main] - tcpKeepAlive = false 2021-05-31 10:24:42.092[INFO] [main] - tcpSndBuf = 65536 2021-05-31 10:24:42.093[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 10:24:42.093[INFO] [main] - useEpoll = false 2021-05-31 10:24:42.093[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 10:24:42.093[INFO] [main] - startTcp = true 2021-05-31 10:24:42.094[INFO] [main] - tcpPort = 1883 2021-05-31 10:24:42.094[INFO] [main] - startWebsocket = false 2021-05-31 10:24:42.094[INFO] [main] - websocketPort = 8883 2021-05-31 10:24:42.094[INFO] [main] - startHttp = true 2021-05-31 10:24:42.095[INFO] [main] - httpPort = 1881 2021-05-31 10:24:42.095[INFO] [main] - startSslTcp = false 2021-05-31 10:24:42.095[INFO] [main] - sslTcpPort = 1884 2021-05-31 10:24:42.095[INFO] [main] - startSslWebsocket = false 2021-05-31 10:24:42.095[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 10:24:42.096[INFO] [main] - useClientCA = false 2021-05-31 10:24:42.096[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 10:24:42.096[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 10:24:42.097[INFO] [main] - sslManagerPwd = 654321 2021-05-31 10:24:42.097[INFO] [main] - sslStorePwd = 654321 2021-05-31 10:24:42.097[INFO] [main] - maxMsgSize = 524288 2021-05-31 10:24:42.097[INFO] [main] - bugsnagEnable = false 2021-05-31 10:24:42.097[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 10:24:42.097[INFO] [main] - channelTimeout = 30 2021-05-31 10:24:42.097[INFO] [main] - useMetrics = true 2021-05-31 10:25:48.098[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 10:25:48.099[INFO] [main] - logLevel = INFO 2021-05-31 10:25:48.099[INFO] [main] - PRE = mqtt.broker. 2021-05-31 10:25:48.099[INFO] [main] - version = 1.0.0 2021-05-31 10:25:48.099[INFO] [main] - anonymousEnable = true 2021-05-31 10:25:48.099[INFO] [main] - pollThreadNum = 16 2021-05-31 10:25:48.100[INFO] [main] - maxPollEventNum = 10 2021-05-31 10:25:48.100[INFO] [main] - pollWaitInterval = 10 2021-05-31 10:25:48.100[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 10:25:48.100[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 10:25:48.100[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 10:25:48.100[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 10:25:48.100[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 10:25:48.101[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 10:25:48.101[INFO] [main] - redisPort = 6379 2021-05-31 10:25:48.101[INFO] [main] - pool = false 2021-05-31 10:25:48.101[INFO] [main] - redisDb = 2 2021-05-31 10:25:48.101[INFO] [main] - redisPassword = 2021-05-31 10:25:48.102[INFO] [main] - maxWaitMills = 60000 2021-05-31 10:25:48.102[INFO] [main] - testOnBorrow = true 2021-05-31 10:25:48.102[INFO] [main] - minIdle = 20 2021-05-31 10:25:48.102[INFO] [main] - maxTotal = 200 2021-05-31 10:25:48.103[INFO] [main] - maxIdle = 50 2021-05-31 10:25:48.103[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 10:25:48.103[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 10:25:48.103[INFO] [main] - username = root 2021-05-31 10:25:48.103[INFO] [main] - password = 12345678 2021-05-31 10:25:48.103[INFO] [main] - highPerformance = false 2021-05-31 10:25:48.103[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 10:25:48.104[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 10:25:48.104[INFO] [main] - kafkaAcks = -1 2021-05-31 10:25:48.104[INFO] [main] - kafkaRetries = 3 2021-05-31 10:25:48.104[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 10:25:48.104[INFO] [main] - kafkaLingerMs = 1 2021-05-31 10:25:48.104[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 10:25:48.104[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 10:25:48.104[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 10:25:48.105[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 10:25:48.105[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 10:25:48.105[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 10:25:48.105[INFO] [main] - pollDuration = 200 2021-05-31 10:25:48.105[INFO] [main] - clientId = test 2021-05-31 10:25:48.105[INFO] [main] - groupId = group_test 2021-05-31 10:25:48.105[INFO] [main] - autoCommit = true 2021-05-31 10:25:48.106[INFO] [main] - autoCommitInterval = 100 2021-05-31 10:25:48.106[INFO] [main] - tcpBackLog = 1024 2021-05-31 10:25:48.106[INFO] [main] - tcpNoDelay = false 2021-05-31 10:25:48.106[INFO] [main] - tcpReuseAddr = true 2021-05-31 10:25:48.106[INFO] [main] - tcpKeepAlive = false 2021-05-31 10:25:48.106[INFO] [main] - tcpSndBuf = 65536 2021-05-31 10:25:48.106[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 10:25:48.106[INFO] [main] - useEpoll = false 2021-05-31 10:25:48.107[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 10:25:48.107[INFO] [main] - startTcp = true 2021-05-31 10:25:48.107[INFO] [main] - tcpPort = 1883 2021-05-31 10:25:48.107[INFO] [main] - startWebsocket = false 2021-05-31 10:25:48.107[INFO] [main] - websocketPort = 8883 2021-05-31 10:25:48.107[INFO] [main] - startHttp = true 2021-05-31 10:25:48.107[INFO] [main] - httpPort = 1881 2021-05-31 10:25:48.107[INFO] [main] - startSslTcp = false 2021-05-31 10:25:48.107[INFO] [main] - sslTcpPort = 1884 2021-05-31 10:25:48.108[INFO] [main] - startSslWebsocket = false 2021-05-31 10:25:48.108[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 10:25:48.108[INFO] [main] - useClientCA = false 2021-05-31 10:25:48.108[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 10:25:48.108[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 10:25:48.108[INFO] [main] - sslManagerPwd = 654321 2021-05-31 10:25:48.108[INFO] [main] - sslStorePwd = 654321 2021-05-31 10:25:48.108[INFO] [main] - maxMsgSize = 524288 2021-05-31 10:25:48.108[INFO] [main] - bugsnagEnable = false 2021-05-31 10:25:48.109[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 10:25:48.109[INFO] [main] - channelTimeout = 30 2021-05-31 10:25:48.109[INFO] [main] - useMetrics = true 2021-05-31 10:25:52.970[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 11:21:33.338[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 11:21:33.346[INFO] [main] - logLevel = INFO 2021-05-31 11:21:33.347[INFO] [main] - PRE = mqtt.broker. 2021-05-31 11:21:33.347[INFO] [main] - version = 1.0.0 2021-05-31 11:21:33.347[INFO] [main] - anonymousEnable = true 2021-05-31 11:21:33.347[INFO] [main] - pollThreadNum = 16 2021-05-31 11:21:33.348[INFO] [main] - maxPollEventNum = 10 2021-05-31 11:21:33.348[INFO] [main] - pollWaitInterval = 10 2021-05-31 11:21:33.348[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 11:21:33.349[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 11:21:33.349[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 11:21:33.349[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 11:21:33.350[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 11:21:33.350[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 11:21:33.350[INFO] [main] - redisPort = 6379 2021-05-31 11:21:33.350[INFO] [main] - pool = false 2021-05-31 11:21:33.350[INFO] [main] - redisDb = 2 2021-05-31 11:21:33.351[INFO] [main] - redisPassword = 2021-05-31 11:21:33.351[INFO] [main] - maxWaitMills = 60000 2021-05-31 11:21:33.351[INFO] [main] - testOnBorrow = true 2021-05-31 11:21:33.351[INFO] [main] - minIdle = 20 2021-05-31 11:21:33.351[INFO] [main] - maxTotal = 200 2021-05-31 11:21:33.351[INFO] [main] - maxIdle = 50 2021-05-31 11:21:33.351[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 11:21:33.352[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 11:21:33.352[INFO] [main] - username = root 2021-05-31 11:21:33.352[INFO] [main] - password = 12345678 2021-05-31 11:21:33.352[INFO] [main] - highPerformance = false 2021-05-31 11:21:33.352[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 11:21:33.353[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 11:21:33.353[INFO] [main] - kafkaAcks = -1 2021-05-31 11:21:33.353[INFO] [main] - kafkaRetries = 3 2021-05-31 11:21:33.353[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 11:21:33.353[INFO] [main] - kafkaLingerMs = 1 2021-05-31 11:21:33.353[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 11:21:33.353[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 11:21:33.354[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 11:21:33.354[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 11:21:33.354[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 11:21:33.354[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 11:21:33.354[INFO] [main] - pollDuration = 200 2021-05-31 11:21:33.354[INFO] [main] - clientId = test 2021-05-31 11:21:33.354[INFO] [main] - groupId = group_test 2021-05-31 11:21:33.354[INFO] [main] - autoCommit = true 2021-05-31 11:21:33.355[INFO] [main] - autoCommitInterval = 100 2021-05-31 11:21:33.355[INFO] [main] - tcpBackLog = 1024 2021-05-31 11:21:33.355[INFO] [main] - tcpNoDelay = false 2021-05-31 11:21:33.355[INFO] [main] - tcpReuseAddr = true 2021-05-31 11:21:33.355[INFO] [main] - tcpKeepAlive = false 2021-05-31 11:21:33.356[INFO] [main] - tcpSndBuf = 65536 2021-05-31 11:21:33.356[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 11:21:33.356[INFO] [main] - useEpoll = false 2021-05-31 11:21:33.356[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 11:21:33.356[INFO] [main] - startTcp = true 2021-05-31 11:21:33.356[INFO] [main] - tcpPort = 1883 2021-05-31 11:21:33.356[INFO] [main] - startWebsocket = false 2021-05-31 11:21:33.356[INFO] [main] - websocketPort = 8883 2021-05-31 11:21:33.357[INFO] [main] - startHttp = true 2021-05-31 11:21:33.357[INFO] [main] - httpPort = 1881 2021-05-31 11:21:33.357[INFO] [main] - startSslTcp = false 2021-05-31 11:21:33.357[INFO] [main] - sslTcpPort = 1884 2021-05-31 11:21:33.357[INFO] [main] - startSslWebsocket = false 2021-05-31 11:21:33.357[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 11:21:33.357[INFO] [main] - useClientCA = false 2021-05-31 11:21:33.357[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 11:21:33.358[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 11:21:33.358[INFO] [main] - sslManagerPwd = 654321 2021-05-31 11:21:33.358[INFO] [main] - sslStorePwd = 654321 2021-05-31 11:21:33.358[INFO] [main] - maxMsgSize = 524288 2021-05-31 11:21:33.358[INFO] [main] - bugsnagEnable = false 2021-05-31 11:21:33.358[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 11:21:33.358[INFO] [main] - channelTimeout = 30 2021-05-31 11:21:33.358[INFO] [main] - useMetrics = true 2021-05-31 11:21:46.834[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:15:12.361[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:15:12.367[INFO] [main] - logLevel = INFO 2021-05-31 16:15:12.367[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:15:12.367[INFO] [main] - version = 1.0.0 2021-05-31 16:15:12.368[INFO] [main] - anonymousEnable = true 2021-05-31 16:15:12.368[INFO] [main] - pollThreadNum = 16 2021-05-31 16:15:12.368[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:15:12.368[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:15:12.368[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:15:12.369[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:15:12.369[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:15:12.369[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:15:12.369[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:15:12.370[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:15:12.370[INFO] [main] - redisPort = 6379 2021-05-31 16:15:12.370[INFO] [main] - pool = false 2021-05-31 16:15:12.370[INFO] [main] - redisDb = 2 2021-05-31 16:15:12.370[INFO] [main] - redisPassword = 2021-05-31 16:15:12.371[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:15:12.371[INFO] [main] - testOnBorrow = true 2021-05-31 16:15:12.371[INFO] [main] - minIdle = 20 2021-05-31 16:15:12.371[INFO] [main] - maxTotal = 200 2021-05-31 16:15:12.371[INFO] [main] - maxIdle = 50 2021-05-31 16:15:12.371[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:15:12.371[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:15:12.372[INFO] [main] - username = root 2021-05-31 16:15:12.372[INFO] [main] - password = 12345678 2021-05-31 16:15:12.372[INFO] [main] - highPerformance = false 2021-05-31 16:15:12.372[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:15:12.372[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:15:12.372[INFO] [main] - kafkaAcks = -1 2021-05-31 16:15:12.372[INFO] [main] - kafkaRetries = 3 2021-05-31 16:15:12.373[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:15:12.373[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:15:12.373[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:15:12.373[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:15:12.373[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:15:12.373[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:15:12.374[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:15:12.374[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:15:12.374[INFO] [main] - pollDuration = 200 2021-05-31 16:15:12.374[INFO] [main] - clientId = test 2021-05-31 16:15:12.374[INFO] [main] - groupId = group_test 2021-05-31 16:15:12.374[INFO] [main] - autoCommit = true 2021-05-31 16:15:12.374[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:15:12.375[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@5939a379 2021-05-31 16:15:12.375[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:15:12.375[INFO] [main] - tcpNoDelay = false 2021-05-31 16:15:12.375[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:15:12.376[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:15:12.376[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:15:12.376[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:15:12.376[INFO] [main] - useEpoll = false 2021-05-31 16:15:12.376[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:15:12.377[INFO] [main] - startTcp = true 2021-05-31 16:15:12.377[INFO] [main] - tcpPort = 1883 2021-05-31 16:15:12.377[INFO] [main] - startWebsocket = false 2021-05-31 16:15:12.377[INFO] [main] - websocketPort = 8883 2021-05-31 16:15:12.377[INFO] [main] - startHttp = true 2021-05-31 16:15:12.378[INFO] [main] - httpPort = 1881 2021-05-31 16:15:12.378[INFO] [main] - startSslTcp = false 2021-05-31 16:15:12.378[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:15:12.378[INFO] [main] - startSslWebsocket = false 2021-05-31 16:15:12.378[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:15:12.378[INFO] [main] - useClientCA = false 2021-05-31 16:15:12.379[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:15:12.379[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:15:12.379[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:15:12.379[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:15:12.379[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:15:12.380[INFO] [main] - bugsnagEnable = false 2021-05-31 16:15:12.380[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:15:12.380[INFO] [main] - channelTimeout = 30 2021-05-31 16:15:12.380[INFO] [main] - useMetrics = true 2021-05-31 16:15:16.757[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:15:50.226[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:15:50.233[INFO] [main] - logLevel = INFO 2021-05-31 16:15:50.234[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:15:50.234[INFO] [main] - version = 1.0.0 2021-05-31 16:15:50.234[INFO] [main] - anonymousEnable = true 2021-05-31 16:15:50.234[INFO] [main] - pollThreadNum = 16 2021-05-31 16:15:50.235[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:15:50.235[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:15:50.235[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:15:50.236[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:15:50.237[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:15:50.237[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:15:50.237[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:15:50.237[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:15:50.237[INFO] [main] - redisPort = 6379 2021-05-31 16:15:50.237[INFO] [main] - pool = false 2021-05-31 16:15:50.238[INFO] [main] - redisDb = 2 2021-05-31 16:15:50.238[INFO] [main] - redisPassword = 2021-05-31 16:15:50.238[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:15:50.238[INFO] [main] - testOnBorrow = true 2021-05-31 16:15:50.238[INFO] [main] - minIdle = 20 2021-05-31 16:15:50.238[INFO] [main] - maxTotal = 200 2021-05-31 16:15:50.238[INFO] [main] - maxIdle = 50 2021-05-31 16:15:50.239[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:15:50.239[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:15:50.239[INFO] [main] - username = root 2021-05-31 16:15:50.239[INFO] [main] - password = 12345678 2021-05-31 16:15:50.240[INFO] [main] - highPerformance = false 2021-05-31 16:15:50.243[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:15:50.243[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:15:50.244[INFO] [main] - kafkaAcks = -1 2021-05-31 16:15:50.244[INFO] [main] - kafkaRetries = 3 2021-05-31 16:15:50.244[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:15:50.244[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:15:50.245[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:15:50.245[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:15:50.245[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:15:50.245[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:15:50.245[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:15:50.245[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:15:50.246[INFO] [main] - pollDuration = 200 2021-05-31 16:15:50.246[INFO] [main] - clientId = test 2021-05-31 16:15:50.246[INFO] [main] - groupId = group_test 2021-05-31 16:15:50.246[INFO] [main] - autoCommit = true 2021-05-31 16:15:50.246[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:15:50.246[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@51a9ad5e 2021-05-31 16:15:50.247[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:15:50.247[INFO] [main] - tcpNoDelay = false 2021-05-31 16:15:50.247[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:15:50.247[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:15:50.247[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:15:50.247[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:15:50.248[INFO] [main] - useEpoll = false 2021-05-31 16:15:50.248[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:15:50.249[INFO] [main] - startTcp = true 2021-05-31 16:15:50.249[INFO] [main] - tcpPort = 1883 2021-05-31 16:15:50.249[INFO] [main] - startWebsocket = false 2021-05-31 16:15:50.249[INFO] [main] - websocketPort = 8883 2021-05-31 16:15:50.250[INFO] [main] - startHttp = true 2021-05-31 16:15:50.250[INFO] [main] - httpPort = 1881 2021-05-31 16:15:50.250[INFO] [main] - startSslTcp = false 2021-05-31 16:15:50.250[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:15:50.250[INFO] [main] - startSslWebsocket = false 2021-05-31 16:15:50.250[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:15:50.251[INFO] [main] - useClientCA = false 2021-05-31 16:15:50.251[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:15:50.251[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:15:50.251[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:15:50.251[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:15:50.252[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:15:50.252[INFO] [main] - bugsnagEnable = false 2021-05-31 16:15:50.252[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:15:50.252[INFO] [main] - channelTimeout = 30 2021-05-31 16:15:50.252[INFO] [main] - useMetrics = true 2021-05-31 16:16:12.084[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:16:12.088[INFO] [main] - logLevel = INFO 2021-05-31 16:16:12.088[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:16:12.088[INFO] [main] - version = 1.0.0 2021-05-31 16:16:12.088[INFO] [main] - anonymousEnable = true 2021-05-31 16:16:12.088[INFO] [main] - pollThreadNum = 16 2021-05-31 16:16:12.088[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:16:12.088[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:16:12.088[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:16:12.089[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:16:12.089[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:16:12.089[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:16:12.089[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:16:12.089[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:16:12.089[INFO] [main] - redisPort = 6379 2021-05-31 16:16:12.090[INFO] [main] - pool = false 2021-05-31 16:16:12.090[INFO] [main] - redisDb = 2 2021-05-31 16:16:12.090[INFO] [main] - redisPassword = 2021-05-31 16:16:12.090[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:16:12.090[INFO] [main] - testOnBorrow = true 2021-05-31 16:16:12.090[INFO] [main] - minIdle = 20 2021-05-31 16:16:12.090[INFO] [main] - maxTotal = 200 2021-05-31 16:16:12.090[INFO] [main] - maxIdle = 50 2021-05-31 16:16:12.090[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:16:12.091[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:16:12.091[INFO] [main] - username = root 2021-05-31 16:16:12.091[INFO] [main] - password = 12345678 2021-05-31 16:16:12.091[INFO] [main] - highPerformance = false 2021-05-31 16:16:12.091[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:16:12.091[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:16:12.091[INFO] [main] - kafkaAcks = -1 2021-05-31 16:16:12.092[INFO] [main] - kafkaRetries = 3 2021-05-31 16:16:12.092[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:16:12.092[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:16:12.092[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:16:12.092[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:16:12.092[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:16:12.096[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:16:12.096[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:16:12.097[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:16:12.097[INFO] [main] - pollDuration = 200 2021-05-31 16:16:12.097[INFO] [main] - clientId = test 2021-05-31 16:16:12.097[INFO] [main] - groupId = group_test 2021-05-31 16:16:12.097[INFO] [main] - autoCommit = true 2021-05-31 16:16:12.098[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:16:12.098[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@51a9ad5e 2021-05-31 16:16:12.098[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:16:12.098[INFO] [main] - tcpNoDelay = false 2021-05-31 16:16:12.098[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:16:12.099[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:16:12.099[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:16:12.099[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:16:12.099[INFO] [main] - useEpoll = false 2021-05-31 16:16:12.099[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:16:12.099[INFO] [main] - startTcp = true 2021-05-31 16:16:12.100[INFO] [main] - tcpPort = 1883 2021-05-31 16:16:12.100[INFO] [main] - startWebsocket = false 2021-05-31 16:16:12.100[INFO] [main] - websocketPort = 8883 2021-05-31 16:16:12.100[INFO] [main] - startHttp = true 2021-05-31 16:16:12.100[INFO] [main] - httpPort = 1881 2021-05-31 16:16:12.100[INFO] [main] - startSslTcp = false 2021-05-31 16:16:12.100[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:16:12.101[INFO] [main] - startSslWebsocket = false 2021-05-31 16:16:12.101[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:16:12.101[INFO] [main] - useClientCA = false 2021-05-31 16:16:12.101[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:16:12.101[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:16:12.101[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:16:12.102[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:16:12.102[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:16:12.102[INFO] [main] - bugsnagEnable = false 2021-05-31 16:16:12.102[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:16:12.102[INFO] [main] - channelTimeout = 30 2021-05-31 16:16:12.102[INFO] [main] - useMetrics = true 2021-05-31 16:16:16.901[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:19:07.952[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:19:07.957[INFO] [main] - logLevel = INFO 2021-05-31 16:19:07.957[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:19:07.957[INFO] [main] - version = 1.0.0 2021-05-31 16:19:07.957[INFO] [main] - anonymousEnable = true 2021-05-31 16:19:07.958[INFO] [main] - pollThreadNum = 16 2021-05-31 16:19:07.958[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:19:07.958[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:19:07.958[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:19:07.958[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:19:07.958[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:19:07.959[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:19:07.959[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:19:07.959[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:19:07.959[INFO] [main] - redisPort = 6379 2021-05-31 16:19:07.959[INFO] [main] - pool = false 2021-05-31 16:19:07.959[INFO] [main] - redisDb = 2 2021-05-31 16:19:07.960[INFO] [main] - redisPassword = 2021-05-31 16:19:07.960[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:19:07.960[INFO] [main] - testOnBorrow = true 2021-05-31 16:19:07.960[INFO] [main] - minIdle = 20 2021-05-31 16:19:07.960[INFO] [main] - maxTotal = 200 2021-05-31 16:19:07.960[INFO] [main] - maxIdle = 50 2021-05-31 16:19:07.960[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:19:07.961[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:19:07.961[INFO] [main] - username = root 2021-05-31 16:19:07.961[INFO] [main] - password = 12345678 2021-05-31 16:19:07.961[INFO] [main] - highPerformance = false 2021-05-31 16:19:07.961[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:19:07.961[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:19:07.961[INFO] [main] - kafkaAcks = -1 2021-05-31 16:19:07.962[INFO] [main] - kafkaRetries = 3 2021-05-31 16:19:07.962[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:19:07.962[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:19:07.962[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:19:07.962[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:19:07.962[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:19:07.963[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:19:07.963[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:19:07.963[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:19:07.963[INFO] [main] - pollDuration = 200 2021-05-31 16:19:07.963[INFO] [main] - clientId = test 2021-05-31 16:19:07.963[INFO] [main] - groupId = group_test 2021-05-31 16:19:07.963[INFO] [main] - autoCommit = true 2021-05-31 16:19:07.964[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:19:07.964[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@51a9ad5e 2021-05-31 16:19:07.964[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:19:07.964[INFO] [main] - tcpNoDelay = false 2021-05-31 16:19:07.964[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:19:07.964[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:19:07.965[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:19:07.965[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:19:07.965[INFO] [main] - useEpoll = false 2021-05-31 16:19:07.965[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:19:07.965[INFO] [main] - startTcp = true 2021-05-31 16:19:07.965[INFO] [main] - tcpPort = 1883 2021-05-31 16:19:07.965[INFO] [main] - startWebsocket = false 2021-05-31 16:19:07.966[INFO] [main] - websocketPort = 8883 2021-05-31 16:19:07.966[INFO] [main] - startHttp = true 2021-05-31 16:19:07.966[INFO] [main] - httpPort = 1881 2021-05-31 16:19:07.966[INFO] [main] - startSslTcp = false 2021-05-31 16:19:07.966[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:19:07.966[INFO] [main] - startSslWebsocket = false 2021-05-31 16:19:07.966[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:19:07.967[INFO] [main] - useClientCA = false 2021-05-31 16:19:07.967[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:19:07.967[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:19:07.967[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:19:07.967[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:19:07.967[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:19:07.968[INFO] [main] - bugsnagEnable = false 2021-05-31 16:19:07.968[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:19:07.968[INFO] [main] - channelTimeout = 30 2021-05-31 16:19:07.968[INFO] [main] - useMetrics = true 2021-05-31 16:19:12.320[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:20:40.073[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:20:40.077[INFO] [main] - logLevel = INFO 2021-05-31 16:20:40.077[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:20:40.077[INFO] [main] - version = 1.0.0 2021-05-31 16:20:40.077[INFO] [main] - anonymousEnable = true 2021-05-31 16:20:40.077[INFO] [main] - pollThreadNum = 16 2021-05-31 16:20:40.077[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:20:40.078[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:20:40.078[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:20:40.078[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:20:40.078[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:20:40.078[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:20:40.078[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:20:40.079[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:20:40.079[INFO] [main] - redisPort = 6379 2021-05-31 16:20:40.079[INFO] [main] - pool = false 2021-05-31 16:20:40.079[INFO] [main] - redisDb = 2 2021-05-31 16:20:40.079[INFO] [main] - redisPassword = 2021-05-31 16:20:40.079[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:20:40.079[INFO] [main] - testOnBorrow = true 2021-05-31 16:20:40.079[INFO] [main] - minIdle = 20 2021-05-31 16:20:40.080[INFO] [main] - maxTotal = 200 2021-05-31 16:20:40.080[INFO] [main] - maxIdle = 50 2021-05-31 16:20:40.080[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:20:40.080[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:20:40.080[INFO] [main] - username = root 2021-05-31 16:20:40.080[INFO] [main] - password = 12345678 2021-05-31 16:20:40.080[INFO] [main] - highPerformance = false 2021-05-31 16:20:40.080[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:20:40.081[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:20:40.081[INFO] [main] - kafkaAcks = -1 2021-05-31 16:20:40.081[INFO] [main] - kafkaRetries = 3 2021-05-31 16:20:40.081[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:20:40.081[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:20:40.081[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:20:40.081[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:20:40.081[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:20:40.082[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:20:40.082[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:20:40.082[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:20:40.082[INFO] [main] - pollDuration = 200 2021-05-31 16:20:40.082[INFO] [main] - clientId = test 2021-05-31 16:20:40.082[INFO] [main] - groupId = group_test 2021-05-31 16:20:40.082[INFO] [main] - autoCommit = true 2021-05-31 16:20:40.082[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:20:40.082[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@35645047 2021-05-31 16:20:40.083[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:20:40.083[INFO] [main] - tcpNoDelay = false 2021-05-31 16:20:40.083[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:20:40.083[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:20:40.083[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:20:40.083[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:20:40.083[INFO] [main] - useEpoll = false 2021-05-31 16:20:40.083[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:20:40.083[INFO] [main] - startTcp = true 2021-05-31 16:20:40.084[INFO] [main] - tcpPort = 1883 2021-05-31 16:20:40.084[INFO] [main] - startWebsocket = false 2021-05-31 16:20:40.084[INFO] [main] - websocketPort = 8883 2021-05-31 16:20:40.084[INFO] [main] - startHttp = true 2021-05-31 16:20:40.084[INFO] [main] - httpPort = 1881 2021-05-31 16:20:40.084[INFO] [main] - startSslTcp = false 2021-05-31 16:20:40.084[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:20:40.084[INFO] [main] - startSslWebsocket = false 2021-05-31 16:20:40.084[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:20:40.085[INFO] [main] - useClientCA = false 2021-05-31 16:20:40.085[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:20:40.085[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:20:40.085[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:20:40.085[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:20:40.085[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:20:40.085[INFO] [main] - bugsnagEnable = false 2021-05-31 16:20:40.085[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:20:40.085[INFO] [main] - channelTimeout = 30 2021-05-31 16:20:40.086[INFO] [main] - useMetrics = true 2021-05-31 16:20:44.547[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:26:09.882[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:26:09.886[INFO] [main] - logLevel = INFO 2021-05-31 16:26:09.886[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:26:09.886[INFO] [main] - version = 1.0.0 2021-05-31 16:26:09.886[INFO] [main] - anonymousEnable = true 2021-05-31 16:26:09.886[INFO] [main] - pollThreadNum = 16 2021-05-31 16:26:09.887[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:26:09.887[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:26:09.887[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:26:09.887[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:26:09.887[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:26:09.887[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:26:09.888[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:26:09.888[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:26:09.888[INFO] [main] - redisPort = 6379 2021-05-31 16:26:09.888[INFO] [main] - pool = false 2021-05-31 16:26:09.888[INFO] [main] - redisDb = 2 2021-05-31 16:26:09.888[INFO] [main] - redisPassword = 2021-05-31 16:26:09.889[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:26:09.889[INFO] [main] - testOnBorrow = true 2021-05-31 16:26:09.889[INFO] [main] - minIdle = 20 2021-05-31 16:26:09.889[INFO] [main] - maxTotal = 200 2021-05-31 16:26:09.889[INFO] [main] - maxIdle = 50 2021-05-31 16:26:09.889[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:26:09.889[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:26:09.889[INFO] [main] - username = root 2021-05-31 16:26:09.889[INFO] [main] - password = 12345678 2021-05-31 16:26:09.890[INFO] [main] - highPerformance = false 2021-05-31 16:26:09.890[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:26:09.890[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:26:09.890[INFO] [main] - kafkaAcks = -1 2021-05-31 16:26:09.890[INFO] [main] - kafkaRetries = 3 2021-05-31 16:26:09.890[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:26:09.890[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:26:09.890[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:26:09.890[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:26:09.891[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:26:09.891[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:26:09.891[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:26:09.891[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:26:09.891[INFO] [main] - pollDuration = 200 2021-05-31 16:26:09.891[INFO] [main] - clientId = test 2021-05-31 16:26:09.891[INFO] [main] - groupId = group_test 2021-05-31 16:26:09.891[INFO] [main] - autoCommit = true 2021-05-31 16:26:09.891[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:26:09.892[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 16:26:09.892[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:26:09.892[INFO] [main] - tcpNoDelay = false 2021-05-31 16:26:09.892[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:26:09.892[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:26:09.892[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:26:09.892[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:26:09.892[INFO] [main] - useEpoll = false 2021-05-31 16:26:09.893[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:26:09.893[INFO] [main] - startTcp = true 2021-05-31 16:26:09.893[INFO] [main] - tcpPort = 1883 2021-05-31 16:26:09.893[INFO] [main] - startWebsocket = false 2021-05-31 16:26:09.893[INFO] [main] - websocketPort = 8883 2021-05-31 16:26:09.893[INFO] [main] - startHttp = true 2021-05-31 16:26:09.894[INFO] [main] - httpPort = 1881 2021-05-31 16:26:09.894[INFO] [main] - startSslTcp = false 2021-05-31 16:26:09.894[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:26:09.894[INFO] [main] - startSslWebsocket = false 2021-05-31 16:26:09.894[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:26:09.895[INFO] [main] - useClientCA = false 2021-05-31 16:26:09.895[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:26:09.895[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:26:09.895[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:26:09.895[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:26:09.895[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:26:09.895[INFO] [main] - bugsnagEnable = false 2021-05-31 16:26:09.896[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:26:09.896[INFO] [main] - channelTimeout = 30 2021-05-31 16:26:09.896[INFO] [main] - useMetrics = true 2021-05-31 16:26:14.542[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:27:19.539[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:27:19.542[INFO] [main] - logLevel = INFO 2021-05-31 16:27:19.543[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:27:19.543[INFO] [main] - version = 1.0.0 2021-05-31 16:27:19.543[INFO] [main] - anonymousEnable = true 2021-05-31 16:27:19.543[INFO] [main] - pollThreadNum = 16 2021-05-31 16:27:19.543[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:27:19.543[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:27:19.543[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:27:19.544[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:27:19.544[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:27:19.544[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:27:19.544[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:27:19.544[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:27:19.544[INFO] [main] - redisPort = 6379 2021-05-31 16:27:19.545[INFO] [main] - pool = false 2021-05-31 16:27:19.545[INFO] [main] - redisDb = 2 2021-05-31 16:27:19.545[INFO] [main] - redisPassword = 2021-05-31 16:27:19.545[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:27:19.545[INFO] [main] - testOnBorrow = true 2021-05-31 16:27:19.545[INFO] [main] - minIdle = 20 2021-05-31 16:27:19.545[INFO] [main] - maxTotal = 200 2021-05-31 16:27:19.545[INFO] [main] - maxIdle = 50 2021-05-31 16:27:19.545[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:27:19.546[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:27:19.546[INFO] [main] - username = root 2021-05-31 16:27:19.546[INFO] [main] - password = 12345678 2021-05-31 16:27:19.546[INFO] [main] - highPerformance = false 2021-05-31 16:27:19.546[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:27:19.546[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:27:19.547[INFO] [main] - kafkaAcks = -1 2021-05-31 16:27:19.547[INFO] [main] - kafkaRetries = 3 2021-05-31 16:27:19.547[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:27:19.547[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:27:19.547[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:27:19.547[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:27:19.547[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:27:19.547[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:27:19.548[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:27:19.548[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:27:19.548[INFO] [main] - pollDuration = 200 2021-05-31 16:27:19.548[INFO] [main] - clientId = test 2021-05-31 16:27:19.548[INFO] [main] - groupId = group_test 2021-05-31 16:27:19.548[INFO] [main] - autoCommit = true 2021-05-31 16:27:19.548[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:27:19.549[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@35645047 2021-05-31 16:27:19.549[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:27:19.549[INFO] [main] - tcpNoDelay = false 2021-05-31 16:27:19.549[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:27:19.549[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:27:19.549[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:27:19.550[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:27:19.550[INFO] [main] - useEpoll = false 2021-05-31 16:27:19.550[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:27:19.550[INFO] [main] - startTcp = true 2021-05-31 16:27:19.550[INFO] [main] - tcpPort = 1883 2021-05-31 16:27:19.550[INFO] [main] - startWebsocket = false 2021-05-31 16:27:19.550[INFO] [main] - websocketPort = 8883 2021-05-31 16:27:19.550[INFO] [main] - startHttp = true 2021-05-31 16:27:19.551[INFO] [main] - httpPort = 1881 2021-05-31 16:27:19.551[INFO] [main] - startSslTcp = false 2021-05-31 16:27:19.551[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:27:19.551[INFO] [main] - startSslWebsocket = false 2021-05-31 16:27:19.551[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:27:19.551[INFO] [main] - useClientCA = false 2021-05-31 16:27:19.551[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:27:19.552[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:27:19.552[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:27:19.552[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:27:19.552[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:27:19.552[INFO] [main] - bugsnagEnable = false 2021-05-31 16:27:19.552[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:27:19.552[INFO] [main] - channelTimeout = 30 2021-05-31 16:27:19.552[INFO] [main] - useMetrics = true 2021-05-31 16:36:28.865[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:36:28.868[INFO] [main] - logLevel = INFO 2021-05-31 16:36:28.868[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:36:28.868[INFO] [main] - version = 1.0.0 2021-05-31 16:36:28.869[INFO] [main] - anonymousEnable = true 2021-05-31 16:36:28.869[INFO] [main] - pollThreadNum = 16 2021-05-31 16:36:28.869[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:36:28.869[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:36:28.869[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:36:28.869[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:36:28.870[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:36:28.870[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:36:28.870[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:36:28.870[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:36:28.871[INFO] [main] - redisPort = 6379 2021-05-31 16:36:28.871[INFO] [main] - pool = false 2021-05-31 16:36:28.871[INFO] [main] - redisDb = 2 2021-05-31 16:36:28.871[INFO] [main] - redisPassword = 2021-05-31 16:36:28.871[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:36:28.871[INFO] [main] - testOnBorrow = true 2021-05-31 16:36:28.871[INFO] [main] - minIdle = 20 2021-05-31 16:36:28.872[INFO] [main] - maxTotal = 200 2021-05-31 16:36:28.872[INFO] [main] - maxIdle = 50 2021-05-31 16:36:28.872[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:36:28.872[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:36:28.872[INFO] [main] - username = root 2021-05-31 16:36:28.872[INFO] [main] - password = 12345678 2021-05-31 16:36:28.872[INFO] [main] - highPerformance = false 2021-05-31 16:36:28.872[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:36:28.873[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:36:28.873[INFO] [main] - kafkaAcks = -1 2021-05-31 16:36:28.873[INFO] [main] - kafkaRetries = 3 2021-05-31 16:36:28.873[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:36:28.873[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:36:28.873[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:36:28.873[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:36:28.874[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:36:28.874[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:36:28.874[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:36:28.874[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:36:28.874[INFO] [main] - pollDuration = 200 2021-05-31 16:36:28.874[INFO] [main] - clientId = test 2021-05-31 16:36:28.874[INFO] [main] - groupId = group_test 2021-05-31 16:36:28.874[INFO] [main] - autoCommit = true 2021-05-31 16:36:28.875[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:36:28.875[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 16:36:28.875[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:36:28.875[INFO] [main] - tcpNoDelay = false 2021-05-31 16:36:28.875[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:36:28.876[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:36:28.876[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:36:28.876[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:36:28.876[INFO] [main] - useEpoll = false 2021-05-31 16:36:28.876[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:36:28.876[INFO] [main] - startTcp = true 2021-05-31 16:36:28.876[INFO] [main] - tcpPort = 1883 2021-05-31 16:36:28.877[INFO] [main] - startWebsocket = false 2021-05-31 16:36:28.877[INFO] [main] - websocketPort = 8883 2021-05-31 16:36:28.877[INFO] [main] - startHttp = true 2021-05-31 16:36:28.877[INFO] [main] - httpPort = 1881 2021-05-31 16:36:28.877[INFO] [main] - startSslTcp = false 2021-05-31 16:36:28.877[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:36:28.878[INFO] [main] - startSslWebsocket = false 2021-05-31 16:36:28.878[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:36:28.878[INFO] [main] - useClientCA = false 2021-05-31 16:36:28.878[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:36:28.878[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:36:28.878[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:36:28.879[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:36:28.879[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:36:28.879[INFO] [main] - bugsnagEnable = false 2021-05-31 16:36:28.879[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:36:28.879[INFO] [main] - channelTimeout = 30 2021-05-31 16:36:28.879[INFO] [main] - useMetrics = true 2021-05-31 16:36:33.295[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:39:19.516[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:39:19.519[INFO] [main] - logLevel = INFO 2021-05-31 16:39:19.520[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:39:19.520[INFO] [main] - version = 1.0.0 2021-05-31 16:39:19.520[INFO] [main] - anonymousEnable = true 2021-05-31 16:39:19.520[INFO] [main] - pollThreadNum = 16 2021-05-31 16:39:19.520[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:39:19.520[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:39:19.521[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:39:19.521[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:39:19.521[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:39:19.521[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:39:19.521[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:39:19.521[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:39:19.522[INFO] [main] - redisPort = 6379 2021-05-31 16:39:19.522[INFO] [main] - pool = false 2021-05-31 16:39:19.522[INFO] [main] - redisDb = 2 2021-05-31 16:39:19.522[INFO] [main] - redisPassword = 2021-05-31 16:39:19.522[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:39:19.522[INFO] [main] - testOnBorrow = true 2021-05-31 16:39:19.522[INFO] [main] - minIdle = 20 2021-05-31 16:39:19.522[INFO] [main] - maxTotal = 200 2021-05-31 16:39:19.523[INFO] [main] - maxIdle = 50 2021-05-31 16:39:19.523[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:39:19.523[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:39:19.523[INFO] [main] - username = root 2021-05-31 16:39:19.523[INFO] [main] - password = 12345678 2021-05-31 16:39:19.523[INFO] [main] - highPerformance = false 2021-05-31 16:39:19.523[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:39:19.523[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:39:19.524[INFO] [main] - kafkaAcks = -1 2021-05-31 16:39:19.524[INFO] [main] - kafkaRetries = 3 2021-05-31 16:39:19.524[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:39:19.524[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:39:19.524[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:39:19.524[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:39:19.525[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:39:19.525[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:39:19.525[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:39:19.525[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:39:19.525[INFO] [main] - pollDuration = 200 2021-05-31 16:39:19.525[INFO] [main] - clientId = test 2021-05-31 16:39:19.526[INFO] [main] - groupId = group_test 2021-05-31 16:39:19.526[INFO] [main] - autoCommit = true 2021-05-31 16:39:19.526[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:39:19.526[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 16:39:19.526[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:39:19.526[INFO] [main] - tcpNoDelay = false 2021-05-31 16:39:19.526[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:39:19.527[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:39:19.527[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:39:19.527[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:39:19.527[INFO] [main] - useEpoll = false 2021-05-31 16:39:19.527[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:39:19.527[INFO] [main] - startTcp = true 2021-05-31 16:39:19.528[INFO] [main] - tcpPort = 1883 2021-05-31 16:39:19.528[INFO] [main] - startWebsocket = false 2021-05-31 16:39:19.528[INFO] [main] - websocketPort = 8883 2021-05-31 16:39:19.528[INFO] [main] - startHttp = true 2021-05-31 16:39:19.528[INFO] [main] - httpPort = 1881 2021-05-31 16:39:19.528[INFO] [main] - startSslTcp = false 2021-05-31 16:39:19.528[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:39:19.528[INFO] [main] - startSslWebsocket = false 2021-05-31 16:39:19.529[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:39:19.529[INFO] [main] - useClientCA = false 2021-05-31 16:39:19.529[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:39:19.529[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:39:19.529[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:39:19.529[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:39:19.529[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:39:19.530[INFO] [main] - bugsnagEnable = false 2021-05-31 16:39:19.531[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:39:19.531[INFO] [main] - channelTimeout = 30 2021-05-31 16:39:19.531[INFO] [main] - useMetrics = true 2021-05-31 16:39:23.968[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:41:40.534[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:41:40.537[INFO] [main] - logLevel = INFO 2021-05-31 16:41:40.538[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:41:40.538[INFO] [main] - version = 1.0.0 2021-05-31 16:41:40.538[INFO] [main] - anonymousEnable = true 2021-05-31 16:41:40.538[INFO] [main] - pollThreadNum = 16 2021-05-31 16:41:40.538[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:41:40.539[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:41:40.539[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:41:40.539[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:41:40.539[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:41:40.539[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:41:40.540[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:41:40.540[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:41:40.540[INFO] [main] - redisPort = 6379 2021-05-31 16:41:40.540[INFO] [main] - pool = false 2021-05-31 16:41:40.540[INFO] [main] - redisDb = 2 2021-05-31 16:41:40.540[INFO] [main] - redisPassword = 2021-05-31 16:41:40.540[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:41:40.540[INFO] [main] - testOnBorrow = true 2021-05-31 16:41:40.541[INFO] [main] - minIdle = 20 2021-05-31 16:41:40.541[INFO] [main] - maxTotal = 200 2021-05-31 16:41:40.541[INFO] [main] - maxIdle = 50 2021-05-31 16:41:40.541[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:41:40.541[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:41:40.541[INFO] [main] - username = root 2021-05-31 16:41:40.541[INFO] [main] - password = 12345678 2021-05-31 16:41:40.541[INFO] [main] - highPerformance = false 2021-05-31 16:41:40.541[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:41:40.542[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:41:40.542[INFO] [main] - kafkaAcks = -1 2021-05-31 16:41:40.542[INFO] [main] - kafkaRetries = 3 2021-05-31 16:41:40.542[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:41:40.542[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:41:40.542[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:41:40.542[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:41:40.542[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:41:40.543[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:41:40.543[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:41:40.543[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:41:40.543[INFO] [main] - pollDuration = 200 2021-05-31 16:41:40.543[INFO] [main] - clientId = test 2021-05-31 16:41:40.543[INFO] [main] - groupId = group_test 2021-05-31 16:41:40.543[INFO] [main] - autoCommit = true 2021-05-31 16:41:40.543[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:41:40.543[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 16:41:40.544[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:41:40.544[INFO] [main] - tcpNoDelay = false 2021-05-31 16:41:40.544[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:41:40.544[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:41:40.544[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:41:40.544[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:41:40.544[INFO] [main] - useEpoll = false 2021-05-31 16:41:40.544[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:41:40.544[INFO] [main] - startTcp = true 2021-05-31 16:41:40.545[INFO] [main] - tcpPort = 1883 2021-05-31 16:41:40.545[INFO] [main] - startWebsocket = false 2021-05-31 16:41:40.545[INFO] [main] - websocketPort = 8883 2021-05-31 16:41:40.545[INFO] [main] - startHttp = true 2021-05-31 16:41:40.545[INFO] [main] - httpPort = 1881 2021-05-31 16:41:40.545[INFO] [main] - startSslTcp = false 2021-05-31 16:41:40.545[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:41:40.545[INFO] [main] - startSslWebsocket = false 2021-05-31 16:41:40.546[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:41:40.546[INFO] [main] - useClientCA = false 2021-05-31 16:41:40.546[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:41:40.546[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:41:40.546[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:41:40.546[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:41:40.546[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:41:40.547[INFO] [main] - bugsnagEnable = false 2021-05-31 16:41:40.547[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:41:40.547[INFO] [main] - channelTimeout = 30 2021-05-31 16:41:40.547[INFO] [main] - useMetrics = true 2021-05-31 16:41:45.014[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:42:56.538[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:42:56.540[INFO] [main] - logLevel = INFO 2021-05-31 16:42:56.541[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:42:56.541[INFO] [main] - version = 1.0.0 2021-05-31 16:42:56.541[INFO] [main] - anonymousEnable = true 2021-05-31 16:42:56.541[INFO] [main] - pollThreadNum = 16 2021-05-31 16:42:56.541[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:42:56.541[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:42:56.541[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:42:56.542[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:42:56.542[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:42:56.542[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:42:56.542[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:42:56.542[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:42:56.542[INFO] [main] - redisPort = 6379 2021-05-31 16:42:56.542[INFO] [main] - pool = false 2021-05-31 16:42:56.542[INFO] [main] - redisDb = 2 2021-05-31 16:42:56.543[INFO] [main] - redisPassword = 2021-05-31 16:42:56.543[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:42:56.543[INFO] [main] - testOnBorrow = true 2021-05-31 16:42:56.543[INFO] [main] - minIdle = 20 2021-05-31 16:42:56.543[INFO] [main] - maxTotal = 200 2021-05-31 16:42:56.543[INFO] [main] - maxIdle = 50 2021-05-31 16:42:56.543[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:42:56.543[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:42:56.543[INFO] [main] - username = root 2021-05-31 16:42:56.543[INFO] [main] - password = 12345678 2021-05-31 16:42:56.544[INFO] [main] - highPerformance = false 2021-05-31 16:42:56.544[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:42:56.544[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:42:56.544[INFO] [main] - kafkaAcks = -1 2021-05-31 16:42:56.544[INFO] [main] - kafkaRetries = 3 2021-05-31 16:42:56.544[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:42:56.544[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:42:56.544[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:42:56.544[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:42:56.545[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:42:56.545[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:42:56.545[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:42:56.545[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:42:56.545[INFO] [main] - pollDuration = 200 2021-05-31 16:42:56.545[INFO] [main] - clientId = test 2021-05-31 16:42:56.545[INFO] [main] - groupId = group_test 2021-05-31 16:42:56.545[INFO] [main] - autoCommit = true 2021-05-31 16:42:56.545[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:42:56.545[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 16:42:56.546[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:42:56.546[INFO] [main] - tcpNoDelay = false 2021-05-31 16:42:56.546[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:42:56.546[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:42:56.546[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:42:56.546[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:42:56.546[INFO] [main] - useEpoll = false 2021-05-31 16:42:56.546[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:42:56.546[INFO] [main] - startTcp = true 2021-05-31 16:42:56.547[INFO] [main] - tcpPort = 1883 2021-05-31 16:42:56.547[INFO] [main] - startWebsocket = false 2021-05-31 16:42:56.547[INFO] [main] - websocketPort = 8883 2021-05-31 16:42:56.547[INFO] [main] - startHttp = true 2021-05-31 16:42:56.547[INFO] [main] - httpPort = 1881 2021-05-31 16:42:56.547[INFO] [main] - startSslTcp = false 2021-05-31 16:42:56.547[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:42:56.548[INFO] [main] - startSslWebsocket = false 2021-05-31 16:42:56.548[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:42:56.548[INFO] [main] - useClientCA = false 2021-05-31 16:42:56.548[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:42:56.548[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:42:56.548[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:42:56.549[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:42:56.549[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:42:56.549[INFO] [main] - bugsnagEnable = false 2021-05-31 16:42:56.549[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:42:56.549[INFO] [main] - channelTimeout = 30 2021-05-31 16:42:56.549[INFO] [main] - useMetrics = true 2021-05-31 16:43:00.886[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 16:48:30.162[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 16:48:30.166[INFO] [main] - logLevel = INFO 2021-05-31 16:48:30.166[INFO] [main] - PRE = mqtt.broker. 2021-05-31 16:48:30.166[INFO] [main] - version = 1.0.0 2021-05-31 16:48:30.166[INFO] [main] - anonymousEnable = true 2021-05-31 16:48:30.166[INFO] [main] - pollThreadNum = 16 2021-05-31 16:48:30.166[INFO] [main] - maxPollEventNum = 10 2021-05-31 16:48:30.167[INFO] [main] - pollWaitInterval = 10 2021-05-31 16:48:30.167[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 16:48:30.167[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 16:48:30.167[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 16:48:30.167[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 16:48:30.167[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 16:48:30.168[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 16:48:30.168[INFO] [main] - redisPort = 6379 2021-05-31 16:48:30.168[INFO] [main] - pool = false 2021-05-31 16:48:30.168[INFO] [main] - redisDb = 2 2021-05-31 16:48:30.168[INFO] [main] - redisPassword = 2021-05-31 16:48:30.168[INFO] [main] - maxWaitMills = 60000 2021-05-31 16:48:30.168[INFO] [main] - testOnBorrow = true 2021-05-31 16:48:30.169[INFO] [main] - minIdle = 20 2021-05-31 16:48:30.169[INFO] [main] - maxTotal = 200 2021-05-31 16:48:30.169[INFO] [main] - maxIdle = 50 2021-05-31 16:48:30.169[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 16:48:30.169[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 16:48:30.169[INFO] [main] - username = root 2021-05-31 16:48:30.169[INFO] [main] - password = 12345678 2021-05-31 16:48:30.169[INFO] [main] - highPerformance = false 2021-05-31 16:48:30.170[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 16:48:30.170[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 16:48:30.170[INFO] [main] - kafkaAcks = -1 2021-05-31 16:48:30.170[INFO] [main] - kafkaRetries = 3 2021-05-31 16:48:30.170[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 16:48:30.170[INFO] [main] - kafkaLingerMs = 1 2021-05-31 16:48:30.170[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 16:48:30.170[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 16:48:30.171[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 16:48:30.171[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 16:48:30.171[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 16:48:30.171[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 16:48:30.171[INFO] [main] - pollDuration = 200 2021-05-31 16:48:30.171[INFO] [main] - clientId = test 2021-05-31 16:48:30.171[INFO] [main] - groupId = group_test 2021-05-31 16:48:30.171[INFO] [main] - autoCommit = true 2021-05-31 16:48:30.171[INFO] [main] - autoCommitInterval = 100 2021-05-31 16:48:30.172[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 16:48:30.172[INFO] [main] - tcpBackLog = 1024 2021-05-31 16:48:30.172[INFO] [main] - tcpNoDelay = false 2021-05-31 16:48:30.172[INFO] [main] - tcpReuseAddr = true 2021-05-31 16:48:30.172[INFO] [main] - tcpKeepAlive = false 2021-05-31 16:48:30.172[INFO] [main] - tcpSndBuf = 65536 2021-05-31 16:48:30.173[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 16:48:30.173[INFO] [main] - useEpoll = false 2021-05-31 16:48:30.173[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 16:48:30.173[INFO] [main] - startTcp = true 2021-05-31 16:48:30.173[INFO] [main] - tcpPort = 1883 2021-05-31 16:48:30.173[INFO] [main] - startWebsocket = false 2021-05-31 16:48:30.173[INFO] [main] - websocketPort = 8883 2021-05-31 16:48:30.173[INFO] [main] - startHttp = true 2021-05-31 16:48:30.173[INFO] [main] - httpPort = 1881 2021-05-31 16:48:30.173[INFO] [main] - startSslTcp = false 2021-05-31 16:48:30.174[INFO] [main] - sslTcpPort = 1884 2021-05-31 16:48:30.174[INFO] [main] - startSslWebsocket = false 2021-05-31 16:48:30.174[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 16:48:30.174[INFO] [main] - useClientCA = false 2021-05-31 16:48:30.174[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 16:48:30.174[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 16:48:30.174[INFO] [main] - sslManagerPwd = 654321 2021-05-31 16:48:30.174[INFO] [main] - sslStorePwd = 654321 2021-05-31 16:48:30.174[INFO] [main] - maxMsgSize = 524288 2021-05-31 16:48:30.175[INFO] [main] - bugsnagEnable = false 2021-05-31 16:48:30.175[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 16:48:30.175[INFO] [main] - channelTimeout = 30 2021-05-31 16:48:30.175[INFO] [main] - useMetrics = true 2021-05-31 16:48:34.434[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 17:07:57.729[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 17:07:57.732[INFO] [main] - logLevel = INFO 2021-05-31 17:07:57.733[INFO] [main] - PRE = mqtt.broker. 2021-05-31 17:07:57.733[INFO] [main] - version = 1.0.0 2021-05-31 17:07:57.733[INFO] [main] - anonymousEnable = true 2021-05-31 17:07:57.733[INFO] [main] - pollThreadNum = 16 2021-05-31 17:07:57.733[INFO] [main] - maxPollEventNum = 10 2021-05-31 17:07:57.733[INFO] [main] - pollWaitInterval = 10 2021-05-31 17:07:57.733[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 17:07:57.734[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 17:07:57.734[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 17:07:57.734[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 17:07:57.734[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 17:07:57.735[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 17:07:57.735[INFO] [main] - redisPort = 6379 2021-05-31 17:07:57.735[INFO] [main] - pool = false 2021-05-31 17:07:57.735[INFO] [main] - redisDb = 2 2021-05-31 17:07:57.736[INFO] [main] - redisPassword = 2021-05-31 17:07:57.736[INFO] [main] - maxWaitMills = 60000 2021-05-31 17:07:57.736[INFO] [main] - testOnBorrow = true 2021-05-31 17:07:57.736[INFO] [main] - minIdle = 20 2021-05-31 17:07:57.736[INFO] [main] - maxTotal = 200 2021-05-31 17:07:57.737[INFO] [main] - maxIdle = 50 2021-05-31 17:07:57.737[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 17:07:57.737[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 17:07:57.737[INFO] [main] - username = root 2021-05-31 17:07:57.737[INFO] [main] - password = 12345678 2021-05-31 17:07:57.737[INFO] [main] - highPerformance = false 2021-05-31 17:07:57.738[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 17:07:57.738[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 17:07:57.738[INFO] [main] - kafkaAcks = -1 2021-05-31 17:07:57.738[INFO] [main] - kafkaRetries = 3 2021-05-31 17:07:57.738[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 17:07:57.738[INFO] [main] - kafkaLingerMs = 1 2021-05-31 17:07:57.738[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 17:07:57.739[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 17:07:57.739[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 17:07:57.739[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 17:07:57.739[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 17:07:57.739[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 17:07:57.739[INFO] [main] - pollDuration = 200 2021-05-31 17:07:57.740[INFO] [main] - clientId = test 2021-05-31 17:07:57.740[INFO] [main] - groupId = group_test 2021-05-31 17:07:57.740[INFO] [main] - autoCommit = true 2021-05-31 17:07:57.740[INFO] [main] - autoCommitInterval = 100 2021-05-31 17:07:57.740[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 17:07:57.741[INFO] [main] - tcpBackLog = 1024 2021-05-31 17:07:57.741[INFO] [main] - tcpNoDelay = false 2021-05-31 17:07:57.741[INFO] [main] - tcpReuseAddr = true 2021-05-31 17:07:57.741[INFO] [main] - tcpKeepAlive = false 2021-05-31 17:07:57.741[INFO] [main] - tcpSndBuf = 65536 2021-05-31 17:07:57.741[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 17:07:57.742[INFO] [main] - useEpoll = false 2021-05-31 17:07:57.742[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 17:07:57.742[INFO] [main] - startTcp = true 2021-05-31 17:07:57.742[INFO] [main] - tcpPort = 1883 2021-05-31 17:07:57.742[INFO] [main] - startWebsocket = false 2021-05-31 17:07:57.742[INFO] [main] - websocketPort = 8883 2021-05-31 17:07:57.743[INFO] [main] - startHttp = true 2021-05-31 17:07:57.743[INFO] [main] - httpPort = 1881 2021-05-31 17:07:57.743[INFO] [main] - startSslTcp = false 2021-05-31 17:07:57.743[INFO] [main] - sslTcpPort = 1884 2021-05-31 17:07:57.743[INFO] [main] - startSslWebsocket = false 2021-05-31 17:07:57.744[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 17:07:57.744[INFO] [main] - useClientCA = false 2021-05-31 17:07:57.744[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 17:07:57.744[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 17:07:57.745[INFO] [main] - sslManagerPwd = 654321 2021-05-31 17:07:57.745[INFO] [main] - sslStorePwd = 654321 2021-05-31 17:07:57.745[INFO] [main] - maxMsgSize = 524288 2021-05-31 17:07:57.745[INFO] [main] - bugsnagEnable = false 2021-05-31 17:07:57.745[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 17:07:57.745[INFO] [main] - channelTimeout = 30 2021-05-31 17:07:57.746[INFO] [main] - useMetrics = true 2021-05-31 17:08:02.590[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 17:12:50.628[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 17:12:50.631[INFO] [main] - logLevel = INFO 2021-05-31 17:12:50.631[INFO] [main] - PRE = mqtt.broker. 2021-05-31 17:12:50.631[INFO] [main] - version = 1.0.0 2021-05-31 17:12:50.631[INFO] [main] - anonymousEnable = true 2021-05-31 17:12:50.632[INFO] [main] - pollThreadNum = 16 2021-05-31 17:12:50.632[INFO] [main] - maxPollEventNum = 10 2021-05-31 17:12:50.632[INFO] [main] - pollWaitInterval = 10 2021-05-31 17:12:50.632[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 17:12:50.632[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 17:12:50.633[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 17:12:50.633[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 17:12:50.633[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 17:12:50.633[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 17:12:50.633[INFO] [main] - redisPort = 6379 2021-05-31 17:12:50.633[INFO] [main] - pool = false 2021-05-31 17:12:50.633[INFO] [main] - redisDb = 2 2021-05-31 17:12:50.634[INFO] [main] - redisPassword = 2021-05-31 17:12:50.634[INFO] [main] - maxWaitMills = 60000 2021-05-31 17:12:50.634[INFO] [main] - testOnBorrow = true 2021-05-31 17:12:50.634[INFO] [main] - minIdle = 20 2021-05-31 17:12:50.634[INFO] [main] - maxTotal = 200 2021-05-31 17:12:50.634[INFO] [main] - maxIdle = 50 2021-05-31 17:12:50.634[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 17:12:50.634[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 17:12:50.634[INFO] [main] - username = root 2021-05-31 17:12:50.634[INFO] [main] - password = 12345678 2021-05-31 17:12:50.634[INFO] [main] - highPerformance = false 2021-05-31 17:12:50.635[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 17:12:50.635[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 17:12:50.635[INFO] [main] - kafkaAcks = -1 2021-05-31 17:12:50.635[INFO] [main] - kafkaRetries = 3 2021-05-31 17:12:50.635[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 17:12:50.635[INFO] [main] - kafkaLingerMs = 1 2021-05-31 17:12:50.635[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 17:12:50.635[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 17:12:50.635[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 17:12:50.636[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 17:12:50.636[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 17:12:50.636[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 17:12:50.636[INFO] [main] - pollDuration = 200 2021-05-31 17:12:50.636[INFO] [main] - clientId = test 2021-05-31 17:12:50.636[INFO] [main] - groupId = group_test 2021-05-31 17:12:50.636[INFO] [main] - autoCommit = true 2021-05-31 17:12:50.636[INFO] [main] - autoCommitInterval = 100 2021-05-31 17:12:50.636[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 17:12:50.637[INFO] [main] - tcpBackLog = 1024 2021-05-31 17:12:50.637[INFO] [main] - tcpNoDelay = false 2021-05-31 17:12:50.637[INFO] [main] - tcpReuseAddr = true 2021-05-31 17:12:50.637[INFO] [main] - tcpKeepAlive = false 2021-05-31 17:12:50.637[INFO] [main] - tcpSndBuf = 65536 2021-05-31 17:12:50.637[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 17:12:50.637[INFO] [main] - useEpoll = false 2021-05-31 17:12:50.637[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 17:12:50.637[INFO] [main] - startTcp = true 2021-05-31 17:12:50.638[INFO] [main] - tcpPort = 1883 2021-05-31 17:12:50.638[INFO] [main] - startWebsocket = false 2021-05-31 17:12:50.638[INFO] [main] - websocketPort = 8883 2021-05-31 17:12:50.638[INFO] [main] - startHttp = true 2021-05-31 17:12:50.638[INFO] [main] - httpPort = 1881 2021-05-31 17:12:50.638[INFO] [main] - startSslTcp = false 2021-05-31 17:12:50.638[INFO] [main] - sslTcpPort = 1884 2021-05-31 17:12:50.638[INFO] [main] - startSslWebsocket = false 2021-05-31 17:12:50.638[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 17:12:50.639[INFO] [main] - useClientCA = false 2021-05-31 17:12:50.639[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 17:12:50.639[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 17:12:50.639[INFO] [main] - sslManagerPwd = 654321 2021-05-31 17:12:50.639[INFO] [main] - sslStorePwd = 654321 2021-05-31 17:12:50.639[INFO] [main] - maxMsgSize = 524288 2021-05-31 17:12:50.639[INFO] [main] - bugsnagEnable = false 2021-05-31 17:12:50.639[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 17:12:50.639[INFO] [main] - channelTimeout = 30 2021-05-31 17:12:50.639[INFO] [main] - useMetrics = true 2021-05-31 17:12:54.865[INFO] [main] - Mqtt Server start success and version = 1.0.0 2021-05-31 17:21:45.391[INFO] [main] - mqttHome = E:\iot\AEP4.0\branch\master\iot-broker\mqtt-broker\src\main\resources 2021-05-31 17:21:45.395[INFO] [main] - logLevel = INFO 2021-05-31 17:21:45.395[INFO] [main] - PRE = mqtt.broker. 2021-05-31 17:21:45.395[INFO] [main] - version = 1.0.0 2021-05-31 17:21:45.395[INFO] [main] - anonymousEnable = true 2021-05-31 17:21:45.395[INFO] [main] - pollThreadNum = 16 2021-05-31 17:21:45.395[INFO] [main] - maxPollEventNum = 10 2021-05-31 17:21:45.395[INFO] [main] - pollWaitInterval = 10 2021-05-31 17:21:45.396[INFO] [main] - sessionStoreClass = com.mortals.mqtt.broker.store.rdb.RDBSessionStore 2021-05-31 17:21:45.396[INFO] [main] - messageStoreClass = com.mortals.mqtt.broker.store.rdb.RDBMessageStore 2021-05-31 17:21:45.396[INFO] [main] - authValidClass = com.mortals.mqtt.broker.services.auth.DefaultAuthServiceImpl 2021-05-31 17:21:45.396[INFO] [main] - clusterEventHandlerClass = com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler 2021-05-31 17:21:45.396[INFO] [main] - msgQueueClass = com.mortals.common.queue.kafka.KafkaMsgQueueFactory 2021-05-31 17:21:45.397[INFO] [main] - redisHost = 127.0.0.1 2021-05-31 17:21:45.397[INFO] [main] - redisPort = 6379 2021-05-31 17:21:45.397[INFO] [main] - pool = false 2021-05-31 17:21:45.397[INFO] [main] - redisDb = 2 2021-05-31 17:21:45.397[INFO] [main] - redisPassword = 2021-05-31 17:21:45.397[INFO] [main] - maxWaitMills = 60000 2021-05-31 17:21:45.397[INFO] [main] - testOnBorrow = true 2021-05-31 17:21:45.397[INFO] [main] - minIdle = 20 2021-05-31 17:21:45.398[INFO] [main] - maxTotal = 200 2021-05-31 17:21:45.398[INFO] [main] - maxIdle = 50 2021-05-31 17:21:45.398[INFO] [main] - driver = com.mysql.cj.jdbc.Driver 2021-05-31 17:21:45.398[INFO] [main] - url = jdbc:mysql://127.0.0.1:3306/mqtt?characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=UTC 2021-05-31 17:21:45.398[INFO] [main] - username = root 2021-05-31 17:21:45.398[INFO] [main] - password = 12345678 2021-05-31 17:21:45.398[INFO] [main] - highPerformance = false 2021-05-31 17:21:45.398[INFO] [main] - kafkaBrokerEnabled = true 2021-05-31 17:21:45.399[INFO] [main] - kafkaServerAddr = 192.168.2.95:17070 2021-05-31 17:21:45.399[INFO] [main] - kafkaAcks = -1 2021-05-31 17:21:45.399[INFO] [main] - kafkaRetries = 3 2021-05-31 17:21:45.399[INFO] [main] - kafkaBatchSize = 16384 2021-05-31 17:21:45.399[INFO] [main] - kafkaLingerMs = 1 2021-05-31 17:21:45.399[INFO] [main] - kafkaBufferMemory = 33554432 2021-05-31 17:21:45.399[INFO] [main] - kafkaKeySerializerClass = org.apache.kafka.common.serialization.StringSerializer 2021-05-31 17:21:45.399[INFO] [main] - kafkaValueSerializerClass = org.apache.kafka.common.serialization.ByteArraySerializer 2021-05-31 17:21:45.399[INFO] [main] - kafkaPartitionerClass = cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner 2021-05-31 17:21:45.399[INFO] [main] - kafkaProducerTopic = Cust_UpDecode_cdbao 2021-05-31 17:21:45.400[INFO] [main] - kafkaConsumerTopic = cdbaoSUB 2021-05-31 17:21:45.400[INFO] [main] - pollDuration = 200 2021-05-31 17:21:45.400[INFO] [main] - clientId = test 2021-05-31 17:21:45.400[INFO] [main] - groupId = group_test 2021-05-31 17:21:45.400[INFO] [main] - autoCommit = true 2021-05-31 17:21:45.400[INFO] [main] - autoCommitInterval = 100 2021-05-31 17:21:45.400[INFO] [main] - metricRegistry = com.codahale.metrics.MetricRegistry@63376bed 2021-05-31 17:21:45.401[INFO] [main] - tcpBackLog = 1024 2021-05-31 17:21:45.401[INFO] [main] - tcpNoDelay = false 2021-05-31 17:21:45.401[INFO] [main] - tcpReuseAddr = true 2021-05-31 17:21:45.401[INFO] [main] - tcpKeepAlive = false 2021-05-31 17:21:45.401[INFO] [main] - tcpSndBuf = 65536 2021-05-31 17:21:45.401[INFO] [main] - tcpRcvBuf = 65536 2021-05-31 17:21:45.401[INFO] [main] - useEpoll = false 2021-05-31 17:21:45.401[INFO] [main] - pooledByteBufAllocatorEnable = false 2021-05-31 17:21:45.401[INFO] [main] - startTcp = true 2021-05-31 17:21:45.402[INFO] [main] - tcpPort = 1883 2021-05-31 17:21:45.402[INFO] [main] - startWebsocket = false 2021-05-31 17:21:45.402[INFO] [main] - websocketPort = 8883 2021-05-31 17:21:45.402[INFO] [main] - startHttp = true 2021-05-31 17:21:45.402[INFO] [main] - httpPort = 1881 2021-05-31 17:21:45.402[INFO] [main] - startSslTcp = false 2021-05-31 17:21:45.402[INFO] [main] - sslTcpPort = 1884 2021-05-31 17:21:45.402[INFO] [main] - startSslWebsocket = false 2021-05-31 17:21:45.402[INFO] [main] - sslWebsocketPort = 8884 2021-05-31 17:21:45.403[INFO] [main] - useClientCA = false 2021-05-31 17:21:45.403[INFO] [main] - sslKeyStoreType = PKCS12 2021-05-31 17:21:45.403[INFO] [main] - sslKeyFilePath = /conf/server.pfx 2021-05-31 17:21:45.403[INFO] [main] - sslManagerPwd = 654321 2021-05-31 17:21:45.403[INFO] [main] - sslStorePwd = 654321 2021-05-31 17:21:45.403[INFO] [main] - maxMsgSize = 524288 2021-05-31 17:21:45.403[INFO] [main] - bugsnagEnable = false 2021-05-31 17:21:45.403[INFO] [main] - bugsnagToken = bugsnag.token 2021-05-31 17:21:45.403[INFO] [main] - channelTimeout = 30 2021-05-31 17:21:45.404[INFO] [main] - useMetrics = true 2021-05-31 17:21:49.941[INFO] [main] - Mqtt Server start success and version = 1.0.0