2021-05-28 08:42:35.738[ERROR] [pool-2-thread-1] - [Consumer clientId=test, groupId=group_test] Offset commit failed on partition topicTest-0 at offset 1533: The coordinator is not aware of this member.
2021-05-28 08:42:58.853[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:127) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:74) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:10:22.281[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:10:22.349[ERROR] [MqttDispatcherSystem-akka.actor.internal-dispatcher-14] - Supervisor StopSupervisor saw failure: Trying to remove Actor[akka://MqttDispatcherSystem/user/MqttEvent#-883966453] for ServiceKey[akka.actor.typed.internal.pubsub.TopicImpl$Command](mqtt-event) but that has never been registered
java.lang.IllegalArgumentException: Trying to remove Actor[akka://MqttDispatcherSystem/user/MqttEvent#-883966453] for ServiceKey[akka.actor.typed.internal.pubsub.TopicImpl$Command](mqtt-event) but that has never been registered
	at akka.cluster.typed.internal.receptionist.ClusterReceptionist$State.removeLocalService(ClusterReceptionist.scala:165) ~[akka-cluster-typed_2.13-2.6.14.jar:2.6.14]
	at akka.cluster.typed.internal.receptionist.ClusterReceptionist$.onCommand$1(ClusterReceptionist.scala:364) ~[akka-cluster-typed_2.13-2.6.14.jar:2.6.14]
	at akka.cluster.typed.internal.receptionist.ClusterReceptionist$.$anonfun$behavior$25(ClusterReceptionist.scala:593) ~[akka-cluster-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.BehaviorImpl$ReceiveBehavior.receive(BehaviorImpl.scala:136) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpret(Behavior.scala:274) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpretMessage(Behavior.scala:230) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.InterceptorImpl$$anon$2.apply(InterceptorImpl.scala:57) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.SimpleSupervisor.aroundReceive(Supervision.scala:124) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.InterceptorImpl.receive(InterceptorImpl.scala:85) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpret(Behavior.scala:274) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpretMessage(Behavior.scala:230) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.adapter.ActorAdapter.handleMessage(ActorAdapter.scala:128) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.adapter.ActorAdapter.aroundReceive(ActorAdapter.scala:107) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.invoke(ActorCell.scala:547) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.run(Mailbox.scala:231) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) [?:1.8.0_231]
2021-05-28 14:11:51.043[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.057[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.058[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.060[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.061[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.062[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.062[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.063[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.064[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topictopicTest
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$2(ConsumerService.java:56) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 14:11:51.105[ERROR] [MqttDispatcherSystem-akka.actor.internal-dispatcher-7] - Supervisor StopSupervisor saw failure: Trying to remove Actor[akka://MqttDispatcherSystem/user/MqttEvent#-28399578] for ServiceKey[akka.actor.typed.internal.pubsub.TopicImpl$Command](mqtt-event) but that has never been registered
java.lang.IllegalArgumentException: Trying to remove Actor[akka://MqttDispatcherSystem/user/MqttEvent#-28399578] for ServiceKey[akka.actor.typed.internal.pubsub.TopicImpl$Command](mqtt-event) but that has never been registered
	at akka.cluster.typed.internal.receptionist.ClusterReceptionist$State.removeLocalService(ClusterReceptionist.scala:165) ~[akka-cluster-typed_2.13-2.6.14.jar:2.6.14]
	at akka.cluster.typed.internal.receptionist.ClusterReceptionist$.onCommand$1(ClusterReceptionist.scala:364) ~[akka-cluster-typed_2.13-2.6.14.jar:2.6.14]
	at akka.cluster.typed.internal.receptionist.ClusterReceptionist$.$anonfun$behavior$25(ClusterReceptionist.scala:593) ~[akka-cluster-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.BehaviorImpl$ReceiveBehavior.receive(BehaviorImpl.scala:136) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpret(Behavior.scala:274) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpretMessage(Behavior.scala:230) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.InterceptorImpl$$anon$2.apply(InterceptorImpl.scala:57) ~[akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.SimpleSupervisor.aroundReceive(Supervision.scala:124) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.InterceptorImpl.receive(InterceptorImpl.scala:85) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpret(Behavior.scala:274) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.Behavior$.interpretMessage(Behavior.scala:230) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.adapter.ActorAdapter.handleMessage(ActorAdapter.scala:128) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.typed.internal.adapter.ActorAdapter.aroundReceive(ActorAdapter.scala:107) [akka-actor-typed_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.invoke(ActorCell.scala:547) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.run(Mailbox.scala:231) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) [?:1.8.0_231]
2021-05-28 14:38:47.647[ERROR] [pool-2-thread-1] - [Consumer clientId=test, groupId=group_test] Metadata response reported invalid topics [cdbao*]
2021-05-28 14:43:47.660[ERROR] [pool-2-thread-1] - [Consumer clientId=test, groupId=group_test] Metadata response reported invalid topics [cdbao*]
2021-05-28 16:01:32.423[ERROR] [pool-2-thread-1] - [Consumer clientId=test, groupId=group_test] Metadata response reported invalid topics [cdbao*]
2021-05-28 16:01:32.425[ERROR] [pool-2-thread-1] - comsumer error
org.apache.kafka.common.errors.InvalidTopicException: Invalid topics: [cdbao*]
2021-05-28 16:03:54.017[ERROR] [pool-2-thread-1] - comsumer error
java.lang.NullPointerException: null
	at com.mortals.common.cluster.dispatcher.akka.AkkaClusterEventHandler.sendEvent(AkkaClusterEventHandler.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.sendContrlMessage2Cluster(ConsumerService.java:129) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$0(ConsumerService.java:95) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 16:08:04.498[ERROR] [pool-2-thread-1] - comsumer error
java.lang.NullPointerException: null
	at java.lang.String.<init>(String.java:491) ~[?:1.8.0_231]
	at com.mortals.mqtt.broker.common.helper.MixAll.convertByteS2Str(MixAll.java:33) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$0(ConsumerService.java:71) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 16:09:33.569[ERROR] [pollMessage2Subscriber_1] - 异常
java.lang.NullPointerException: null
	at com.mortals.mqtt.broker.subscribe.DefaultSubscriptionTreeMatcher.recursionMatch(DefaultSubscriptionTreeMatcher.java:210) ~[classes/:?]
	at com.mortals.mqtt.broker.subscribe.DefaultSubscriptionTreeMatcher.match(DefaultSubscriptionTreeMatcher.java:111) ~[classes/:?]
	at com.mortals.common.cluster.dispatcher.DefaultDispatcherInnerMessage$AsyncDispatcher.run(DefaultDispatcherInnerMessage.java:170) [classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 17:16:27.020[ERROR] [MqttDispatcherSystem-akka.actor.default-dispatcher-3] - Bind failed for TCP channel on endpoint [/127.0.0.1:2551]
java.net.BindException: [/127.0.0.1:2551] Address already in use: bind
	at sun.nio.ch.Net.bind0(Native Method) ~[?:1.8.0_231]
	at sun.nio.ch.Net.bind(Net.java:433) ~[?:1.8.0_231]
	at sun.nio.ch.Net.bind(Net.java:425) ~[?:1.8.0_231]
	at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223) ~[?:1.8.0_231]
	at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) ~[?:1.8.0_231]
	at akka.io.TcpListener.liftedTree1$1(TcpListener.scala:60) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.io.TcpListener.<init>(TcpListener.scala:57) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_231]
	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[?:1.8.0_231]
	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_231]
	at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_231]
	at akka.util.Reflect$.instantiate(Reflect.scala:73) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:101) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.Props.newActor(Props.scala:226) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.newActor(ActorCell.scala:615) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.create(ActorCell.scala:642) ~[akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:513) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.actor.ActorCell.systemInvoke(ActorCell.scala:535) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:295) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.run(Mailbox.scala:230) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [akka-actor_2.13-2.6.14.jar:2.6.14]
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_231]
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) [?:1.8.0_231]
2021-05-28 17:20:43.237[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topiccdbaoSUB
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$0(ConsumerService.java:61) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 17:20:43.251[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topiccdbaoSUB
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$0(ConsumerService.java:61) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
2021-05-28 17:20:43.253[ERROR] [pool-2-thread-1] - poll invoked but consumer stopped for topiccdbaoSUB
java.lang.RuntimeException: stacktrace
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.errorAndReturnEmpty(AbstractTbQueueConsumerTemplate.java:128) ~[classes/:?]
	at com.mortals.common.queue.kafka.AbstractTbQueueConsumerTemplate.poll(AbstractTbQueueConsumerTemplate.java:75) ~[classes/:?]
	at com.mortals.common.queue.ConsumerService.lambda$launchMainConsumers$0(ConsumerService.java:61) ~[classes/:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]