2024-06-23 19:27:16.524 [main] INFO  com.muyu.IotDbApplication:55 - Starting IotDbApplication using Java 17.0.10 on xiaoxin with PID 28152 (D:\work\IotDB\target\classes started by 86157 in D:\work\IotDB)
2024-06-23 19:27:16.531 [main] DEBUG com.muyu.IotDbApplication:56 - Running with Spring Boot v2.6.13, Spring v5.3.23
2024-06-23 19:27:16.532 [main] INFO  com.muyu.IotDbApplication:645 - No active profile set, falling back to 1 default profile: "default"
2024-06-23 19:27:17.085 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:262 - Multiple Spring Data modules found, entering strict repository configuration mode
2024-06-23 19:27:17.088 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:132 - Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2024-06-23 19:27:17.114 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:201 - Finished Spring Data repository scanning in 13 ms. Found 0 Redis repository interfaces.
2024-06-23 19:27:17.354 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'com.dtflys.forest.springboot.ForestAutoConfiguration' of type [com.dtflys.forest.springboot.ForestAutoConfiguration$$EnhancerBySpringCGLIB$$c348bd5f] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.479 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestProperties' of type [com.dtflys.forest.config.SpringForestProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.481 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestObjectFactory' of type [com.dtflys.forest.reflection.SpringForestObjectFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.483 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestInterceptorFactory' of type [com.dtflys.forest.interceptor.SpringInterceptorFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.496 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forest-com.dtflys.forest.springboot.properties.ForestConfigurationProperties' of type [com.dtflys.forest.springboot.properties.ForestConfigurationProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.529 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConfiguration' of type [com.dtflys.forest.config.ForestConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.532 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConverterBeanListener' of type [com.dtflys.forest.spring.ConverterBeanListener] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:27:17.785 [main] INFO  o.s.boot.web.embedded.tomcat.TomcatWebServer:108 - Tomcat initialized with port(s): 8888 (http)
2024-06-23 19:27:17.793 [main] INFO  org.apache.catalina.core.StandardService:173 - Starting service [Tomcat]
2024-06-23 19:27:17.793 [main] INFO  org.apache.catalina.core.StandardEngine:173 - Starting Servlet engine: [Apache Tomcat/9.0.68]
2024-06-23 19:27:17.915 [main] INFO  o.a.c.core.ContainerBase.[Tomcat].[localhost].[/]:173 - Initializing Spring embedded WebApplicationContext
2024-06-23 19:27:17.915 [main] INFO  o.s.b.w.s.c.ServletWebServerApplicationContext:290 - Root WebApplicationContext: initialization completed in 1339 ms
2024-06-23 19:27:18.636 [main] INFO  com.zaxxer.hikari.HikariDataSource:110 - HikariPool-1 - Starting...
2024-06-23 19:27:18.975 [main] INFO  com.zaxxer.hikari.HikariDataSource:123 - HikariPool-1 - Start completed.
2024-06-23 19:27:18.980 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==>  Preparing: select * from vehicle_event
2024-06-23 19:27:18.997 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==> Parameters: 
2024-06-23 19:27:19.048 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - <==      Total: 1
2024-06-23 19:27:19.066 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Partitions-1
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Partitions
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:27:19.134 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:27:19.134 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:27:19.134 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142039132
2024-06-23 19:27:19.136 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Subscribed to topic(s): test1
2024-06-23 19:27:19.410 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 2 : {test1=LEADER_NOT_AVAILABLE}
2024-06-23 19:27:19.411 [Thread-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:27:19.534 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 5 : {test1=LEADER_NOT_AVAILABLE}
2024-06-23 19:27:19.642 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 7 : {test1=LEADER_NOT_AVAILABLE}
2024-06-23 19:27:19.672 [main] INFO  com.muyu.iotDB.config.IotDBSessionConfig:38 - 正在连接iotdb.......
2024-06-23 19:27:19.686 [main] WARN  o.s.b.w.s.c.AnnotationConfigServletWebServerApplicationContext:591 - Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getSession' defined in class path resource [com/muyu/iotDB/config/IotDBSessionConfig.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
2024-06-23 19:27:19.814 [main] INFO  com.zaxxer.hikari.HikariDataSource:350 - HikariPool-1 - Shutdown initiated...
2024-06-23 19:27:19.820 [main] INFO  com.zaxxer.hikari.HikariDataSource:352 - HikariPool-1 - Shutdown completed.
2024-06-23 19:27:19.821 [main] INFO  org.apache.catalina.core.StandardService:173 - Stopping service [Tomcat]
2024-06-23 19:27:19.829 [main] INFO  o.s.b.a.l.ConditionEvaluationReportLoggingListener:136 - 

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2024-06-23 19:27:19.843 [main] ERROR org.springframework.boot.SpringApplication:835 - Application run failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getSession' defined in class path resource [com/muyu/iotDB/config/IotDBSessionConfig.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:658)
	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:486)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1352)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1195)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:582)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208)
	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:955)
	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918)
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583)
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145)
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:745)
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:420)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:307)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1317)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1306)
	at com.muyu.IotDbApplication.main(IotDbApplication.java:12)
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:185)
	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:653)
	... 19 common frames omitted
Caused by: org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.apache.iotdb.session.SessionConnection.init(SessionConnection.java:117)
	at org.apache.iotdb.session.SessionConnection.<init>(SessionConnection.java:97)
	at org.apache.iotdb.session.Session.constructSessionConnection(Session.java:434)
	at org.apache.iotdb.session.Session.open(Session.java:402)
	at org.apache.iotdb.session.Session.open(Session.java:391)
	at com.muyu.iotDB.config.IotDBSessionConfig.getSession(IotDBSessionConfig.java:40)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$a7f306dd.CGLIB$getSession$1(<generated>)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$a7f306dd$$FastClassBySpringCGLIB$$aa245509.invoke(<generated>)
	at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:244)
	at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:331)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$a7f306dd.getSession(<generated>)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154)
	... 20 common frames omitted
Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.apache.thrift.transport.TSocket.open(TSocket.java:243)
	at org.apache.iotdb.rpc.TElasticFramedTransport.open(TElasticFramedTransport.java:91)
	at org.apache.iotdb.session.SessionConnection.init(SessionConnection.java:115)
	... 35 common frames omitted
Caused by: java.net.ConnectException: Connection refused: connect
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:579)
	at java.base/sun.nio.ch.Net.connect(Net.java:568)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:593)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at org.apache.thrift.transport.TSocket.open(TSocket.java:238)
	... 37 common frames omitted
2024-06-23 19:27:20.408 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:27:20.409 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:27:20.429 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:27:20.456 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully joined group with generation Generation{generationId=1, memberId='consumer-Partitions-1-7f9665de-b260-42c5-a8e9-83c78528f428', protocol='range'}
2024-06-23 19:27:20.457 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Finished assignment for group at generation 1: {consumer-Partitions-1-7f9665de-b260-42c5-a8e9-83c78528f428=Assignment(partitions=[test1-0])}
2024-06-23 19:27:20.523 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully synced group in generation Generation{generationId=1, memberId='consumer-Partitions-1-7f9665de-b260-42c5-a8e9-83c78528f428', protocol='range'}
2024-06-23 19:27:20.523 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:27:20.525 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Adding newly assigned partitions: test1-0
2024-06-23 19:27:20.558 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:1354 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Found no committed offset for partition test1-0
2024-06-23 19:27:20.584 [Thread-1] INFO  o.a.k.clients.consumer.internals.SubscriptionState:398 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Resetting offset for partition test1-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}.
2024-06-23 19:29:50.895 [main] INFO  com.muyu.IotDbApplication:55 - Starting IotDbApplication using Java 17.0.10 on xiaoxin with PID 27796 (D:\work\IotDB\target\classes started by 86157 in D:\work\IotDB)
2024-06-23 19:29:50.896 [main] DEBUG com.muyu.IotDbApplication:56 - Running with Spring Boot v2.6.13, Spring v5.3.23
2024-06-23 19:29:50.897 [main] INFO  com.muyu.IotDbApplication:645 - No active profile set, falling back to 1 default profile: "default"
2024-06-23 19:29:51.423 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:262 - Multiple Spring Data modules found, entering strict repository configuration mode
2024-06-23 19:29:51.425 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:132 - Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2024-06-23 19:29:51.447 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:201 - Finished Spring Data repository scanning in 11 ms. Found 0 Redis repository interfaces.
2024-06-23 19:29:51.693 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'com.dtflys.forest.springboot.ForestAutoConfiguration' of type [com.dtflys.forest.springboot.ForestAutoConfiguration$$EnhancerBySpringCGLIB$$1e8412b0] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:51.782 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestProperties' of type [com.dtflys.forest.config.SpringForestProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:51.784 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestObjectFactory' of type [com.dtflys.forest.reflection.SpringForestObjectFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:51.786 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestInterceptorFactory' of type [com.dtflys.forest.interceptor.SpringInterceptorFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:51.800 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forest-com.dtflys.forest.springboot.properties.ForestConfigurationProperties' of type [com.dtflys.forest.springboot.properties.ForestConfigurationProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:51.831 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConfiguration' of type [com.dtflys.forest.config.ForestConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:51.835 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConverterBeanListener' of type [com.dtflys.forest.spring.ConverterBeanListener] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:29:52.080 [main] INFO  o.s.boot.web.embedded.tomcat.TomcatWebServer:108 - Tomcat initialized with port(s): 8888 (http)
2024-06-23 19:29:52.087 [main] INFO  org.apache.catalina.core.StandardService:173 - Starting service [Tomcat]
2024-06-23 19:29:52.088 [main] INFO  org.apache.catalina.core.StandardEngine:173 - Starting Servlet engine: [Apache Tomcat/9.0.68]
2024-06-23 19:29:52.200 [main] INFO  o.a.c.core.ContainerBase.[Tomcat].[localhost].[/]:173 - Initializing Spring embedded WebApplicationContext
2024-06-23 19:29:52.201 [main] INFO  o.s.b.w.s.c.ServletWebServerApplicationContext:290 - Root WebApplicationContext: initialization completed in 1272 ms
2024-06-23 19:29:52.836 [main] INFO  com.zaxxer.hikari.HikariDataSource:110 - HikariPool-1 - Starting...
2024-06-23 19:29:53.173 [main] INFO  com.zaxxer.hikari.HikariDataSource:123 - HikariPool-1 - Start completed.
2024-06-23 19:29:53.180 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==>  Preparing: select * from vehicle_event
2024-06-23 19:29:53.196 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==> Parameters: 
2024-06-23 19:29:53.243 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - <==      Total: 1
2024-06-23 19:29:53.263 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Partitions-1
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Partitions
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:29:53.337 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:29:53.337 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:29:53.337 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142193336
2024-06-23 19:29:53.338 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Subscribed to topic(s): test1
2024-06-23 19:29:53.622 [Thread-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:29:53.623 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:29:53.625 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:29:53.637 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:29:53.640 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully joined group with generation Generation{generationId=3, memberId='consumer-Partitions-1-04f98287-3935-4adb-9eb3-037d2a08d6e5', protocol='range'}
2024-06-23 19:29:53.641 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Finished assignment for group at generation 3: {consumer-Partitions-1-04f98287-3935-4adb-9eb3-037d2a08d6e5=Assignment(partitions=[test1-0])}
2024-06-23 19:29:53.645 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully synced group in generation Generation{generationId=3, memberId='consumer-Partitions-1-04f98287-3935-4adb-9eb3-037d2a08d6e5', protocol='range'}
2024-06-23 19:29:53.646 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:29:53.647 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Adding newly assigned partitions: test1-0
2024-06-23 19:29:53.654 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:820 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Setting offset for partition test1-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}
2024-06-23 19:29:53.852 [main] INFO  com.muyu.iotDB.config.IotDBSessionConfig:38 - 正在连接iotdb.......
2024-06-23 19:29:53.864 [main] WARN  o.s.b.w.s.c.AnnotationConfigServletWebServerApplicationContext:591 - Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getSession' defined in class path resource [com/muyu/iotDB/config/IotDBSessionConfig.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
2024-06-23 19:29:53.982 [main] INFO  com.zaxxer.hikari.HikariDataSource:350 - HikariPool-1 - Shutdown initiated...
2024-06-23 19:29:54.170 [main] INFO  com.zaxxer.hikari.HikariDataSource:352 - HikariPool-1 - Shutdown completed.
2024-06-23 19:29:54.172 [main] INFO  org.apache.catalina.core.StandardService:173 - Stopping service [Tomcat]
2024-06-23 19:29:54.179 [main] INFO  o.s.b.a.l.ConditionEvaluationReportLoggingListener:136 - 

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2024-06-23 19:29:54.193 [main] ERROR org.springframework.boot.SpringApplication:835 - Application run failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getSession' defined in class path resource [com/muyu/iotDB/config/IotDBSessionConfig.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:658)
	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:486)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1352)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1195)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:582)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208)
	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:955)
	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918)
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583)
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145)
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:745)
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:420)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:307)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1317)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1306)
	at com.muyu.IotDbApplication.main(IotDbApplication.java:12)
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:185)
	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:653)
	... 19 common frames omitted
Caused by: org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.apache.iotdb.session.SessionConnection.init(SessionConnection.java:117)
	at org.apache.iotdb.session.SessionConnection.<init>(SessionConnection.java:97)
	at org.apache.iotdb.session.Session.constructSessionConnection(Session.java:434)
	at org.apache.iotdb.session.Session.open(Session.java:402)
	at org.apache.iotdb.session.Session.open(Session.java:391)
	at com.muyu.iotDB.config.IotDBSessionConfig.getSession(IotDBSessionConfig.java:40)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$32e5c2e.CGLIB$getSession$1(<generated>)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$32e5c2e$$FastClassBySpringCGLIB$$f768b227.invoke(<generated>)
	at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:244)
	at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:331)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$32e5c2e.getSession(<generated>)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154)
	... 20 common frames omitted
Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.apache.thrift.transport.TSocket.open(TSocket.java:243)
	at org.apache.iotdb.rpc.TElasticFramedTransport.open(TElasticFramedTransport.java:91)
	at org.apache.iotdb.session.SessionConnection.init(SessionConnection.java:115)
	... 35 common frames omitted
Caused by: java.net.ConnectException: Connection refused: connect
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:579)
	at java.base/sun.nio.ch.Net.connect(Net.java:568)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:593)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at org.apache.thrift.transport.TSocket.open(TSocket.java:238)
	... 37 common frames omitted
2024-06-23 19:30:19.364 [main] INFO  com.muyu.IotDbApplication:55 - Starting IotDbApplication using Java 17.0.10 on xiaoxin with PID 8044 (D:\work\IotDB\target\classes started by 86157 in D:\work\IotDB)
2024-06-23 19:30:19.366 [main] DEBUG com.muyu.IotDbApplication:56 - Running with Spring Boot v2.6.13, Spring v5.3.23
2024-06-23 19:30:19.367 [main] INFO  com.muyu.IotDbApplication:645 - No active profile set, falling back to 1 default profile: "default"
2024-06-23 19:30:19.832 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:262 - Multiple Spring Data modules found, entering strict repository configuration mode
2024-06-23 19:30:19.834 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:132 - Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2024-06-23 19:30:19.855 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:201 - Finished Spring Data repository scanning in 11 ms. Found 0 Redis repository interfaces.
2024-06-23 19:30:20.081 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'com.dtflys.forest.springboot.ForestAutoConfiguration' of type [com.dtflys.forest.springboot.ForestAutoConfiguration$$EnhancerBySpringCGLIB$$1e8412b0] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.164 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestProperties' of type [com.dtflys.forest.config.SpringForestProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.165 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestObjectFactory' of type [com.dtflys.forest.reflection.SpringForestObjectFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.167 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestInterceptorFactory' of type [com.dtflys.forest.interceptor.SpringInterceptorFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.178 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forest-com.dtflys.forest.springboot.properties.ForestConfigurationProperties' of type [com.dtflys.forest.springboot.properties.ForestConfigurationProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.207 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConfiguration' of type [com.dtflys.forest.config.ForestConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.211 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConverterBeanListener' of type [com.dtflys.forest.spring.ConverterBeanListener] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:30:20.423 [main] INFO  o.s.boot.web.embedded.tomcat.TomcatWebServer:108 - Tomcat initialized with port(s): 8888 (http)
2024-06-23 19:30:20.432 [main] INFO  org.apache.catalina.core.StandardService:173 - Starting service [Tomcat]
2024-06-23 19:30:20.432 [main] INFO  org.apache.catalina.core.StandardEngine:173 - Starting Servlet engine: [Apache Tomcat/9.0.68]
2024-06-23 19:30:20.547 [main] INFO  o.a.c.core.ContainerBase.[Tomcat].[localhost].[/]:173 - Initializing Spring embedded WebApplicationContext
2024-06-23 19:30:20.547 [main] INFO  o.s.b.w.s.c.ServletWebServerApplicationContext:290 - Root WebApplicationContext: initialization completed in 1148 ms
2024-06-23 19:30:21.301 [main] INFO  com.zaxxer.hikari.HikariDataSource:110 - HikariPool-1 - Starting...
2024-06-23 19:30:21.659 [main] INFO  com.zaxxer.hikari.HikariDataSource:123 - HikariPool-1 - Start completed.
2024-06-23 19:30:21.664 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==>  Preparing: select * from vehicle_event
2024-06-23 19:30:21.680 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==> Parameters: 
2024-06-23 19:30:21.722 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - <==      Total: 1
2024-06-23 19:30:21.739 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Partitions-1
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Partitions
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:30:21.795 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:30:21.795 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:30:21.795 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142221794
2024-06-23 19:30:21.796 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Subscribed to topic(s): test1
2024-06-23 19:30:22.018 [Thread-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:30:22.019 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:30:22.021 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:30:22.027 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:30:22.029 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully joined group with generation Generation{generationId=5, memberId='consumer-Partitions-1-6892e15a-3298-473b-97cc-6c01710b2ddd', protocol='range'}
2024-06-23 19:30:22.030 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Finished assignment for group at generation 5: {consumer-Partitions-1-6892e15a-3298-473b-97cc-6c01710b2ddd=Assignment(partitions=[test1-0])}
2024-06-23 19:30:22.033 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully synced group in generation Generation{generationId=5, memberId='consumer-Partitions-1-6892e15a-3298-473b-97cc-6c01710b2ddd', protocol='range'}
2024-06-23 19:30:22.035 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:30:22.036 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Adding newly assigned partitions: test1-0
2024-06-23 19:30:22.041 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:820 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Setting offset for partition test1-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}
2024-06-23 19:30:22.281 [main] INFO  com.muyu.iotDB.config.IotDBSessionConfig:38 - 正在连接iotdb.......
2024-06-23 19:30:22.293 [main] WARN  o.s.b.w.s.c.AnnotationConfigServletWebServerApplicationContext:591 - Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getSession' defined in class path resource [com/muyu/iotDB/config/IotDBSessionConfig.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
2024-06-23 19:30:22.437 [main] INFO  com.zaxxer.hikari.HikariDataSource:350 - HikariPool-1 - Shutdown initiated...
2024-06-23 19:30:22.460 [main] INFO  com.zaxxer.hikari.HikariDataSource:352 - HikariPool-1 - Shutdown completed.
2024-06-23 19:30:22.462 [main] INFO  org.apache.catalina.core.StandardService:173 - Stopping service [Tomcat]
2024-06-23 19:30:22.467 [main] INFO  o.s.b.a.l.ConditionEvaluationReportLoggingListener:136 - 

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2024-06-23 19:30:22.480 [main] ERROR org.springframework.boot.SpringApplication:835 - Application run failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'getSession' defined in class path resource [com/muyu/iotDB/config/IotDBSessionConfig.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:658)
	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:486)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1352)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1195)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:582)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542)
	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)
	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)
	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208)
	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:955)
	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918)
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583)
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:145)
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:745)
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:420)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:307)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1317)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1306)
	at com.muyu.IotDbApplication.main(IotDbApplication.java:12)
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.iotdb.session.Session]: Factory method 'getSession' threw exception; nested exception is org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:185)
	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:653)
	... 19 common frames omitted
Caused by: org.apache.iotdb.rpc.IoTDBConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.apache.iotdb.session.SessionConnection.init(SessionConnection.java:117)
	at org.apache.iotdb.session.SessionConnection.<init>(SessionConnection.java:97)
	at org.apache.iotdb.session.Session.constructSessionConnection(Session.java:434)
	at org.apache.iotdb.session.Session.open(Session.java:402)
	at org.apache.iotdb.session.Session.open(Session.java:391)
	at com.muyu.iotDB.config.IotDBSessionConfig.getSession(IotDBSessionConfig.java:40)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$32e5c2e.CGLIB$getSession$1(<generated>)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$32e5c2e$$FastClassBySpringCGLIB$$f768b227.invoke(<generated>)
	at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:244)
	at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:331)
	at com.muyu.iotDB.config.IotDBSessionConfig$$EnhancerBySpringCGLIB$$32e5c2e.getSession(<generated>)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154)
	... 20 common frames omitted
Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
	at org.apache.thrift.transport.TSocket.open(TSocket.java:243)
	at org.apache.iotdb.rpc.TElasticFramedTransport.open(TElasticFramedTransport.java:91)
	at org.apache.iotdb.session.SessionConnection.init(SessionConnection.java:115)
	... 35 common frames omitted
Caused by: java.net.ConnectException: Connection refused: connect
	at java.base/sun.nio.ch.Net.connect0(Native Method)
	at java.base/sun.nio.ch.Net.connect(Net.java:579)
	at java.base/sun.nio.ch.Net.connect(Net.java:568)
	at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:593)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
	at java.base/java.net.Socket.connect(Socket.java:633)
	at org.apache.thrift.transport.TSocket.open(TSocket.java:238)
	... 37 common frames omitted
2024-06-23 19:30:25.451 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:911 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Group coordinator xiaoxin:9092 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: true. Rediscovery will be attempted.
2024-06-23 19:30:25.452 [Thread-1] INFO  org.apache.kafka.clients.FetchSessionHandler:481 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error sending fetch request (sessionId=1792969557, epoch=6) to node 0:
org.apache.kafka.common.errors.DisconnectException: null
2024-06-23 19:30:27.591 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:776 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Connection to node 0 (xiaoxin/192.168.156.123:9092) could not be established. Broker may not be available.
2024-06-23 19:30:27.592 [Thread-1] INFO  org.apache.kafka.clients.FetchSessionHandler:481 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error sending fetch request (sessionId=1792969557, epoch=INITIAL) to node 0:
org.apache.kafka.common.errors.DisconnectException: null
2024-06-23 19:30:29.721 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:776 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Connection to node 0 (xiaoxin/192.168.159.1:9092) could not be established. Broker may not be available.
2024-06-23 19:30:29.722 [Thread-1] INFO  org.apache.kafka.clients.FetchSessionHandler:481 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error sending fetch request (sessionId=1792969557, epoch=INITIAL) to node 0:
org.apache.kafka.common.errors.DisconnectException: null
2024-06-23 19:30:31.503 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 71 : {test1=INVALID_REPLICATION_FACTOR}
2024-06-23 19:30:31.553 [Thread-1] WARN  o.apache.kafka.clients.consumer.internals.Fetcher:1306 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Received unknown topic or partition error in fetch for partition test1-0
2024-06-23 19:30:31.617 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 74 : {test1=INVALID_REPLICATION_FACTOR}
2024-06-23 19:30:31.662 [Thread-1] WARN  o.apache.kafka.clients.consumer.internals.Fetcher:1306 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Received unknown topic or partition error in fetch for partition test1-0
2024-06-23 19:30:31.727 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 77 : {test1=INVALID_REPLICATION_FACTOR}
2024-06-23 19:30:31.772 [Thread-1] WARN  o.apache.kafka.clients.consumer.internals.Fetcher:1306 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Received unknown topic or partition error in fetch for partition test1-0
2024-06-23 19:30:31.840 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 80 : {test1=LEADER_NOT_AVAILABLE}
2024-06-23 19:30:31.881 [Thread-1] WARN  o.apache.kafka.clients.consumer.internals.Fetcher:1306 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Received unknown topic or partition error in fetch for partition test1-0
2024-06-23 19:30:31.949 [Thread-1] WARN  org.apache.kafka.clients.NetworkClient:1100 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Error while fetching metadata with correlation id 84 : {test1=LEADER_NOT_AVAILABLE}
2024-06-23 19:30:31.991 [Thread-1] WARN  o.apache.kafka.clients.consumer.internals.Fetcher:1306 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Received unknown topic or partition error in fetch for partition test1-0
2024-06-23 19:30:32.057 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:30:32.058 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:772 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version2: {test1=1}) to (version4: {})
2024-06-23 19:30:32.058 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:772 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version2: {test1=1}) to (version4: {})
2024-06-23 19:30:32.083 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:307 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Revoke previously assigned partitions test1-0
2024-06-23 19:30:32.083 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:30:32.094 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully joined group with generation Generation{generationId=6, memberId='consumer-Partitions-1-6892e15a-3298-473b-97cc-6c01710b2ddd', protocol='range'}
2024-06-23 19:30:32.095 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Finished assignment for group at generation 6: {consumer-Partitions-1-6892e15a-3298-473b-97cc-6c01710b2ddd=Assignment(partitions=[test1-0])}
2024-06-23 19:30:32.103 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully synced group in generation Generation{generationId=6, memberId='consumer-Partitions-1-6892e15a-3298-473b-97cc-6c01710b2ddd', protocol='range'}
2024-06-23 19:30:32.103 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:30:32.103 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Adding newly assigned partitions: test1-0
2024-06-23 19:30:32.109 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:820 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Setting offset for partition test1-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}
2024-06-23 19:31:31.466 [main] INFO  com.muyu.IotDbApplication:55 - Starting IotDbApplication using Java 17.0.10 on xiaoxin with PID 21232 (D:\work\IotDB\target\classes started by 86157 in D:\work\IotDB)
2024-06-23 19:31:31.466 [main] DEBUG com.muyu.IotDbApplication:56 - Running with Spring Boot v2.6.13, Spring v5.3.23
2024-06-23 19:31:31.467 [main] INFO  com.muyu.IotDbApplication:645 - No active profile set, falling back to 1 default profile: "default"
2024-06-23 19:31:31.964 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:262 - Multiple Spring Data modules found, entering strict repository configuration mode
2024-06-23 19:31:31.966 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:132 - Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2024-06-23 19:31:31.988 [main] INFO  o.s.d.r.config.RepositoryConfigurationDelegate:201 - Finished Spring Data repository scanning in 12 ms. Found 0 Redis repository interfaces.
2024-06-23 19:31:32.232 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'com.dtflys.forest.springboot.ForestAutoConfiguration' of type [com.dtflys.forest.springboot.ForestAutoConfiguration$$EnhancerBySpringCGLIB$$1e8412b0] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.308 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestProperties' of type [com.dtflys.forest.config.SpringForestProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.309 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestObjectFactory' of type [com.dtflys.forest.reflection.SpringForestObjectFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.311 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestInterceptorFactory' of type [com.dtflys.forest.interceptor.SpringInterceptorFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.322 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forest-com.dtflys.forest.springboot.properties.ForestConfigurationProperties' of type [com.dtflys.forest.springboot.properties.ForestConfigurationProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.352 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConfiguration' of type [com.dtflys.forest.config.ForestConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.355 [main] INFO  o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'forestConverterBeanListener' of type [com.dtflys.forest.spring.ConverterBeanListener] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2024-06-23 19:31:32.580 [main] INFO  o.s.boot.web.embedded.tomcat.TomcatWebServer:108 - Tomcat initialized with port(s): 8888 (http)
2024-06-23 19:31:32.587 [main] INFO  org.apache.catalina.core.StandardService:173 - Starting service [Tomcat]
2024-06-23 19:31:32.587 [main] INFO  org.apache.catalina.core.StandardEngine:173 - Starting Servlet engine: [Apache Tomcat/9.0.68]
2024-06-23 19:31:32.692 [main] INFO  o.a.c.core.ContainerBase.[Tomcat].[localhost].[/]:173 - Initializing Spring embedded WebApplicationContext
2024-06-23 19:31:32.692 [main] INFO  o.s.b.w.s.c.ServletWebServerApplicationContext:290 - Root WebApplicationContext: initialization completed in 1195 ms
2024-06-23 19:31:33.341 [main] INFO  com.zaxxer.hikari.HikariDataSource:110 - HikariPool-1 - Starting...
2024-06-23 19:31:33.708 [main] INFO  com.zaxxer.hikari.HikariDataSource:123 - HikariPool-1 - Start completed.
2024-06-23 19:31:33.714 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==>  Preparing: select * from vehicle_event
2024-06-23 19:31:33.730 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - ==> Parameters: 
2024-06-23 19:31:33.781 [main] DEBUG c.muyu.event.mapper.EventMapper.selectVehicleEvent:137 - <==      Total: 1
2024-06-23 19:31:33.801 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Partitions-1
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Partitions
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:31:33.867 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:31:33.867 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:31:33.868 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142293866
2024-06-23 19:31:33.869 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Subscribed to topic(s): test1
2024-06-23 19:31:34.160 [Thread-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:31:34.161 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:31:34.165 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:31:34.176 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] (Re-)joining group
2024-06-23 19:31:34.180 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully joined group with generation Generation{generationId=8, memberId='consumer-Partitions-1-a270c725-e2a9-484f-822b-7c87dd9dc184', protocol='range'}
2024-06-23 19:31:34.181 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Finished assignment for group at generation 8: {consumer-Partitions-1-a270c725-e2a9-484f-822b-7c87dd9dc184=Assignment(partitions=[test1-0])}
2024-06-23 19:31:34.186 [Thread-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Successfully synced group in generation Generation{generationId=8, memberId='consumer-Partitions-1-a270c725-e2a9-484f-822b-7c87dd9dc184', protocol='range'}
2024-06-23 19:31:34.186 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:31:34.188 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Adding newly assigned partitions: test1-0
2024-06-23 19:31:34.194 [Thread-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:820 - [Consumer clientId=consumer-Partitions-1, groupId=Partitions] Setting offset for partition test1-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}
2024-06-23 19:31:34.375 [main] INFO  com.muyu.iotDB.config.IotDBSessionConfig:38 - 正在连接iotdb.......
2024-06-23 19:31:34.498 [main] INFO  com.muyu.iotDB.config.IotDBSessionConfig:42 - iotdb连接成功~
2024-06-23 19:31:35.185 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Topics-2
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Topics
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:31:35.189 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:31:35.189 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:31:35.189 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142295189
2024-06-23 19:31:35.190 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Subscribed to topic(s): test1
2024-06-23 19:31:35.196 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Topics-3
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Topics
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:31:35.199 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:31:35.200 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:31:35.201 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142295199
2024-06-23 19:31:35.201 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Subscribed to topic(s): test1
2024-06-23 19:31:35.202 [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig:372 - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = latest
	bootstrap.servers = [localhost:9092]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-Topics-4
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = Topics
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2024-06-23 19:31:35.204 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:31:35.205 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:31:35.205 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:31:35.205 [main] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142295205
2024-06-23 19:31:35.206 [main] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:965 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Subscribed to topic(s): test1
2024-06-23 19:31:35.207 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:31:35.207 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:31:35.208 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-2, groupId=Topics] (Re-)joining group
2024-06-23 19:31:35.208 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:31:35.208 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-3, groupId=Topics] (Re-)joining group
2024-06-23 19:31:35.209 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  org.apache.kafka.clients.Metadata:279 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:31:35.210 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:848 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Discovered group coordinator xiaoxin:9092 (id: 2147483647 rack: null)
2024-06-23 19:31:35.211 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-4, groupId=Topics] (Re-)joining group
2024-06-23 19:31:35.211 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-2, groupId=Topics] (Re-)joining group
2024-06-23 19:31:35.211 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-3, groupId=Topics] (Re-)joining group
2024-06-23 19:31:35.214 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Successfully joined group with generation Generation{generationId=1, memberId='consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d', protocol='range'}
2024-06-23 19:31:35.214 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Successfully joined group with generation Generation{generationId=1, memberId='consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44', protocol='range'}
2024-06-23 19:31:35.214 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Finished assignment for group at generation 1: {consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44=Assignment(partitions=[test1-0]), consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d=Assignment(partitions=[])}
2024-06-23 19:31:35.214 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-4, groupId=Topics] (Re-)joining group
2024-06-23 19:31:35.216 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Successfully synced group in generation Generation{generationId=1, memberId='consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d', protocol='range'}
2024-06-23 19:31:35.216 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Successfully synced group in generation Generation{generationId=1, memberId='consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44', protocol='range'}
2024-06-23 19:31:35.216 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Notifying assignor about the new Assignment(partitions=[])
2024-06-23 19:31:35.217 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:31:35.217 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Adding newly assigned partitions: 
2024-06-23 19:31:35.217 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Adding newly assigned partitions: test1-0
2024-06-23 19:31:35.217 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions assigned: []
2024-06-23 19:31:35.218 [main] INFO  o.s.boot.web.embedded.tomcat.TomcatWebServer:220 - Tomcat started on port(s): 8888 (http) with context path ''
2024-06-23 19:31:35.218 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:1354 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Found no committed offset for partition test1-0
2024-06-23 19:31:35.220 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:1354 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Found no committed offset for partition test1-0
2024-06-23 19:31:35.230 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.clients.consumer.internals.SubscriptionState:398 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Resetting offset for partition test1-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}.
2024-06-23 19:31:35.233 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions assigned: [test1-0]
2024-06-23 19:31:35.364 [main] INFO  o.s.a.rabbit.connection.CachingConnectionFactory:638 - Attempting to connect to: [101.34.243.166:5672]
2024-06-23 19:31:35.514 [main] INFO  o.s.a.rabbit.connection.CachingConnectionFactory:589 - Created new connection: rabbitConnectionFactory#72a34537:0/SimpleConnection@73c6ebec [delegate=amqp://guest@101.34.243.166:5672/, localPort= 53416]
2024-06-23 19:31:35.952 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-1] INFO  com.muyu.mqtt.MsgHandler:22 - 接收到消息：47.100.60.64,47.102.213.144
2024-06-23 19:31:35.956 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-1] ERROR com.muyu.mqtt.MsgHandler:31 - 接收到消息初始化信息:MqttProperties(broker=tcp://47.100.60.64:1883, topic=test1, username=null, password=null, clientid=protocol-parsing)
2024-06-23 19:31:36.162 [main] INFO  com.muyu.IotDbApplication:61 - Started IotDbApplication in 4.979 seconds (JVM running for 5.471)
2024-06-23 19:31:36.164 [main] INFO  com.muyu.event.KafkaRunner:27 - 项目启动，开始动态启动kafka消费者
2024-06-23 19:31:36.372 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-1] ERROR com.muyu.mqtt.MsgHandler:33 - client创建成功:protocol-parsing
2024-06-23 19:31:36.373 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-1] ERROR com.muyu.mqtt.MsgHandler:31 - 接收到消息初始化信息:MqttProperties(broker=tcp://47.102.213.144:1883, topic=test1, username=null, password=null, clientid=protocol-parsing)
2024-06-23 19:31:36.768 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-1] ERROR com.muyu.mqtt.MsgHandler:33 - client创建成功:protocol-parsing
2024-06-23 19:31:38.216 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:1123 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Attempt to heartbeat failed since group is rebalancing
2024-06-23 19:31:38.217 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:307 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Revoke previously assigned partitions 
2024-06-23 19:31:38.217 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions revoked: []
2024-06-23 19:31:38.218 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-3, groupId=Topics] (Re-)joining group
2024-06-23 19:31:38.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:1123 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Attempt to heartbeat failed since group is rebalancing
2024-06-23 19:31:38.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:307 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Revoke previously assigned partitions test1-0
2024-06-23 19:31:38.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions revoked: [test1-0]
2024-06-23 19:31:38.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:538 - [Consumer clientId=consumer-Topics-2, groupId=Topics] (Re-)joining group
2024-06-23 19:31:38.232 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Successfully joined group with generation Generation{generationId=2, memberId='consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d', protocol='range'}
2024-06-23 19:31:38.233 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Successfully joined group with generation Generation{generationId=2, memberId='consumer-Topics-4-939348d8-793b-4f8d-93e5-a84a9d797463', protocol='range'}
2024-06-23 19:31:38.233 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:594 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Successfully joined group with generation Generation{generationId=2, memberId='consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44', protocol='range'}
2024-06-23 19:31:38.233 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:626 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Finished assignment for group at generation 2: {consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44=Assignment(partitions=[test1-0]), consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d=Assignment(partitions=[]), consumer-Topics-4-939348d8-793b-4f8d-93e5-a84a9d797463=Assignment(partitions=[])}
2024-06-23 19:31:38.236 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Successfully synced group in generation Generation{generationId=2, memberId='consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d', protocol='range'}
2024-06-23 19:31:38.236 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Successfully synced group in generation Generation{generationId=2, memberId='consumer-Topics-4-939348d8-793b-4f8d-93e5-a84a9d797463', protocol='range'}
2024-06-23 19:31:38.236 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:758 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Successfully synced group in generation Generation{generationId=2, memberId='consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44', protocol='range'}
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Notifying assignor about the new Assignment(partitions=[])
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Notifying assignor about the new Assignment(partitions=[test1-0])
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Adding newly assigned partitions: test1-0
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Adding newly assigned partitions: 
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:276 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Notifying assignor about the new Assignment(partitions=[])
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions assigned: []
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:288 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Adding newly assigned partitions: 
2024-06-23 19:31:38.237 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions assigned: []
2024-06-23 19:31:38.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:820 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Setting offset for partition test1-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[xiaoxin:9092 (id: 0 rack: null)], epoch=0}}
2024-06-23 19:31:38.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions assigned: [test1-0]
2024-06-23 19:32:14.237 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:14.237 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:14.237 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 33 34 31 39 36 31 31 36 2e 36 35 35 35 38 30 30 33 39 2e 35 32 30 39 32 32 30 37 32 2e 30 30 30 34 34 2e 32 32 30 30 30 30 30 30 33 30 30 30 30 30 34 30 30 30 30 31 34 37 38 30 30 30 30 30 44 35 30 34 30 31 32 2e 31 30 37 34 30 30 30 30 37 33 37 33 36 36 33 34 30 38 32 30 30 30 30 32 35 39 30 30 31 34 34 37 33 30 30 30 36 30 37 31 30 2e 38 31 30 30 30 30 39 31 30 30 30 30 39 30 39 30 30 30 30 32 35 35 30 30 30 34 30 30 30 33 30 30 30 35 34 30 30 30 30 33 36 30 30 30 30 38 31 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 c9 7E
2024-06-23 19:32:14.256 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142334196, longitude=116.6555800, latitude=39.5209220, speed=72.000, mileage=44.22000000, dischargeVoltage=300000, dischargeCurrent=40000, insulationResistance=147800000, gear=D, accelerationPedal=50, brakePedal=40, fuelConsumption=12.10, motorControllerTemperature=740000, motorSpeed=73736, motorTorque=6340, motorTemperature=820000, motorVoltage=25900, motorCurrent=14473000, powerBattery=60710., maxFeedbackPower=810000, maxDischargePower=910000, bmsSelfCheck=90, powerBatteryCurrent=90000, powerBatteryV3=255000, maxVoltage=4000, minVoltage=3000, maxTemperature=540000, minTemperature=360000, availableCapacity=810000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:14.314 [MQTT Call: protocol-parsing] INFO  org.apache.kafka.clients.producer.ProducerConfig:372 - ProducerConfig values: 
	acks = 1
	batch.size = 16384
	bootstrap.servers = [localhost:9092]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = producer-1
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	internal.auto.downgrade.txn.commit = false
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metadata.max.idle.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer

2024-06-23 19:32:14.330 [MQTT Call: protocol-parsing] INFO  org.apache.kafka.common.utils.AppInfoParser:119 - Kafka version: 2.8.0
2024-06-23 19:32:14.330 [MQTT Call: protocol-parsing] INFO  org.apache.kafka.common.utils.AppInfoParser:120 - Kafka commitId: ebb1d6e21cc92130
2024-06-23 19:32:14.330 [MQTT Call: protocol-parsing] INFO  org.apache.kafka.common.utils.AppInfoParser:121 - Kafka startTimeMs: 1719142334330
2024-06-23 19:32:14.333 [kafka-producer-network-thread | producer-1] INFO  org.apache.kafka.clients.Metadata:279 - [Producer clientId=producer-1] Cluster ID: FVIPWM6mRnC_JFIhGOcq3w
2024-06-23 19:32:14.366 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:14.367 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"50","availableCapacity":"810000","bmsSelfCheck":"90","brakePedal":"40","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"40000","dischargeVoltage":"300000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"12.10","gear":"D","insulationResistance":"147800000","latitude":"39.5209220","location":"1","longitude":"116.6555800","maxDischargePower":"910000","maxFeedbackPower":"810000","maxTemperature":"540000","maxVoltage":"4000","mcu":"1","mileage":"44.22000000","minTemperature":"360000","minVoltage":"3000","motorControllerTemperature":"740000","motorCurrent":"14473000","motorSpeed":"73736","motorTemperature":"820000","motorTorque":"6340","motorVoltage":"25900","powerBattery":"60710.","powerBatteryCurrent":"90000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"255000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142334196","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:14.493 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142334196, longitude=116.6555800, latitude=39.5209220, speed=72.000, mileage=44.22000000, dischargeVoltage=300000, dischargeCurrent=40000, insulationResistance=147800000, gear=D, accelerationPedal=50, brakePedal=40, fuelConsumption=12.10, motorControllerTemperature=740000, motorSpeed=73736, motorTorque=6340, motorTemperature=820000, motorVoltage=25900, motorCurrent=14473000, powerBattery=60710., maxFeedbackPower=810000, maxDischargePower=910000, bmsSelfCheck=90, powerBatteryCurrent=90000, powerBatteryV3=255000, maxVoltage=4000, minVoltage=3000, maxTemperature=540000, minTemperature=360000, availableCapacity=810000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:14.493 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:755 - 故障信息ZEQA6V2Z98M9ZMFZF发送到RabbitMQ
2024-06-23 19:32:14.494 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:239 - 该车故障GZ001信息首次存储到本地缓存和Redis中，并发送到RabbitMQ
2024-06-23 19:32:14.561 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:755 - 故障信息ZEQA6V2Z98M9ZMFZF发送到RabbitMQ
2024-06-23 19:32:14.561 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:304 - 该车故障GZ003信息首次存储到本地缓存和Redis中，并发送到RabbitMQ
2024-06-23 19:32:15.256 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:15.256 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:15.256 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 33 35 32 30 37 31 31 36 2e 36 35 36 33 37 33 30 33 39 2e 35 32 30 39 39 37 30 35 34 2e 30 30 30 34 34 2e 32 35 30 30 30 30 30 30 35 37 33 30 30 30 33 36 30 30 30 31 38 32 39 34 30 30 30 30 44 32 30 39 30 31 31 2e 32 30 37 36 30 30 30 30 37 34 39 34 34 35 30 31 30 38 31 30 30 30 30 31 31 39 30 30 35 31 30 39 30 30 30 30 36 30 37 31 30 2e 32 38 30 30 30 30 38 35 30 30 30 30 31 30 38 30 30 30 30 36 35 34 30 30 30 33 30 30 30 34 30 30 30 38 35 30 30 30 30 36 37 30 30 30 30 36 34 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 e4 7E
2024-06-23 19:32:15.256 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142335207, longitude=116.6563730, latitude=39.5209970, speed=54.000, mileage=44.25000000, dischargeVoltage=573000, dischargeCurrent=36000, insulationResistance=182940000, gear=D, accelerationPedal=20, brakePedal=90, fuelConsumption=11.20, motorControllerTemperature=760000, motorSpeed=74944, motorTorque=5010, motorTemperature=810000, motorVoltage=11900, motorCurrent=51090000, powerBattery=60710., maxFeedbackPower=280000, maxDischargePower=850000, bmsSelfCheck=10, powerBatteryCurrent=80000, powerBatteryV3=654000, maxVoltage=3000, minVoltage=4000, maxTemperature=850000, minTemperature=670000, availableCapacity=640000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:15.265 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:15.265 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"640000","bmsSelfCheck":"10","brakePedal":"90","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"36000","dischargeVoltage":"573000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.20","gear":"D","insulationResistance":"182940000","latitude":"39.5209970","location":"1","longitude":"116.6563730","maxDischargePower":"850000","maxFeedbackPower":"280000","maxTemperature":"850000","maxVoltage":"3000","mcu":"1","mileage":"44.25000000","minTemperature":"670000","minVoltage":"4000","motorControllerTemperature":"760000","motorCurrent":"51090000","motorSpeed":"74944","motorTemperature":"810000","motorTorque":"5010","motorVoltage":"11900","powerBattery":"60710.","powerBatteryCurrent":"80000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"654000","ptc":"1","runStatus":"0","soc":"1","speed":"54.000","timestamp":"1719142335207","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:15.265 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142335207, longitude=116.6563730, latitude=39.5209970, speed=54.000, mileage=44.25000000, dischargeVoltage=573000, dischargeCurrent=36000, insulationResistance=182940000, gear=D, accelerationPedal=20, brakePedal=90, fuelConsumption=11.20, motorControllerTemperature=760000, motorSpeed=74944, motorTorque=5010, motorTemperature=810000, motorVoltage=11900, motorCurrent=51090000, powerBattery=60710., maxFeedbackPower=280000, maxDischargePower=850000, bmsSelfCheck=10, powerBatteryCurrent=80000, powerBatteryV3=654000, maxVoltage=3000, minVoltage=4000, maxTemperature=850000, minTemperature=670000, availableCapacity=640000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:15.328 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:15.394 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:16.242 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:16.242 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:16.242 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 33 36 32 30 35 31 31 36 2e 36 35 37 36 32 39 30 33 39 2e 35 32 31 31 32 31 30 37 32 2e 30 30 30 34 34 2e 32 39 30 30 30 30 30 30 35 39 30 30 30 30 33 36 30 30 30 39 36 33 34 30 30 30 30 30 44 32 30 31 30 31 31 2e 37 30 37 39 30 30 30 30 34 35 34 32 30 39 33 33 30 38 31 30 30 30 30 31 36 38 30 30 36 37 35 32 30 30 30 30 36 30 37 31 30 2e 32 38 30 30 30 30 35 30 30 30 30 30 31 30 31 31 30 30 30 36 37 32 30 30 30 33 30 30 30 34 30 30 30 37 35 30 30 30 30 32 34 30 30 30 30 34 38 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 c6 7E
2024-06-23 19:32:16.242 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142336205, longitude=116.6576290, latitude=39.5211210, speed=72.000, mileage=44.29000000, dischargeVoltage=590000, dischargeCurrent=36000, insulationResistance=963400000, gear=D, accelerationPedal=20, brakePedal=10, fuelConsumption=11.70, motorControllerTemperature=790000, motorSpeed=45420, motorTorque=9330, motorTemperature=810000, motorVoltage=16800, motorCurrent=67520000, powerBattery=60710., maxFeedbackPower=280000, maxDischargePower=500000, bmsSelfCheck=10, powerBatteryCurrent=11000, powerBatteryV3=672000, maxVoltage=3000, minVoltage=4000, maxTemperature=750000, minTemperature=240000, availableCapacity=480000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:16.246 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:16.246 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"480000","bmsSelfCheck":"10","brakePedal":"10","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"36000","dischargeVoltage":"590000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.70","gear":"D","insulationResistance":"963400000","latitude":"39.5211210","location":"1","longitude":"116.6576290","maxDischargePower":"500000","maxFeedbackPower":"280000","maxTemperature":"750000","maxVoltage":"3000","mcu":"1","mileage":"44.29000000","minTemperature":"240000","minVoltage":"4000","motorControllerTemperature":"790000","motorCurrent":"67520000","motorSpeed":"45420","motorTemperature":"810000","motorTorque":"9330","motorVoltage":"16800","powerBattery":"60710.","powerBatteryCurrent":"11000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"672000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142336205","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:16.246 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142336205, longitude=116.6576290, latitude=39.5211210, speed=72.000, mileage=44.29000000, dischargeVoltage=590000, dischargeCurrent=36000, insulationResistance=963400000, gear=D, accelerationPedal=20, brakePedal=10, fuelConsumption=11.70, motorControllerTemperature=790000, motorSpeed=45420, motorTorque=9330, motorTemperature=810000, motorVoltage=16800, motorCurrent=67520000, powerBattery=60710., maxFeedbackPower=280000, maxDischargePower=500000, bmsSelfCheck=10, powerBatteryCurrent=11000, powerBatteryV3=672000, maxVoltage=3000, minVoltage=4000, maxTemperature=750000, minTemperature=240000, availableCapacity=480000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:16.407 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:16.446 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:17.239 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:17.239 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:17.239 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 33 37 32 30 32 31 31 36 2e 36 35 38 34 37 38 30 33 39 2e 35 32 31 31 36 33 30 35 34 2e 30 30 30 34 34 2e 33 32 30 30 30 30 30 30 31 37 31 30 30 30 31 34 30 30 30 32 30 31 36 34 30 30 30 30 44 32 30 30 30 31 30 2e 31 30 34 38 30 30 30 30 37 38 38 35 38 39 38 39 30 34 36 30 30 30 30 31 32 34 30 30 31 35 35 38 30 30 30 30 36 30 37 31 30 2e 38 37 30 30 30 30 38 38 30 30 30 30 38 30 31 31 30 30 30 35 31 30 30 30 30 33 30 30 30 34 30 30 30 35 37 30 30 30 30 33 32 30 30 30 30 33 34 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 c9 7E
2024-06-23 19:32:17.239 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142337202, longitude=116.6584780, latitude=39.5211630, speed=54.000, mileage=44.32000000, dischargeVoltage=171000, dischargeCurrent=14000, insulationResistance=201640000, gear=D, accelerationPedal=20, brakePedal=00, fuelConsumption=10.10, motorControllerTemperature=480000, motorSpeed=78858, motorTorque=9890, motorTemperature=460000, motorVoltage=12400, motorCurrent=15580000, powerBattery=60710., maxFeedbackPower=870000, maxDischargePower=880000, bmsSelfCheck=80, powerBatteryCurrent=11000, powerBatteryV3=510000, maxVoltage=3000, minVoltage=4000, maxTemperature=570000, minTemperature=320000, availableCapacity=340000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:17.242 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:17.242 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"340000","bmsSelfCheck":"80","brakePedal":"00","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"14000","dischargeVoltage":"171000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.10","gear":"D","insulationResistance":"201640000","latitude":"39.5211630","location":"1","longitude":"116.6584780","maxDischargePower":"880000","maxFeedbackPower":"870000","maxTemperature":"570000","maxVoltage":"3000","mcu":"1","mileage":"44.32000000","minTemperature":"320000","minVoltage":"4000","motorControllerTemperature":"480000","motorCurrent":"15580000","motorSpeed":"78858","motorTemperature":"460000","motorTorque":"9890","motorVoltage":"12400","powerBattery":"60710.","powerBatteryCurrent":"11000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"510000","ptc":"1","runStatus":"0","soc":"1","speed":"54.000","timestamp":"1719142337202","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:17.242 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142337202, longitude=116.6584780, latitude=39.5211630, speed=54.000, mileage=44.32000000, dischargeVoltage=171000, dischargeCurrent=14000, insulationResistance=201640000, gear=D, accelerationPedal=20, brakePedal=00, fuelConsumption=10.10, motorControllerTemperature=480000, motorSpeed=78858, motorTorque=9890, motorTemperature=460000, motorVoltage=12400, motorCurrent=15580000, powerBattery=60710., maxFeedbackPower=870000, maxDischargePower=880000, bmsSelfCheck=80, powerBatteryCurrent=11000, powerBatteryV3=510000, maxVoltage=3000, minVoltage=4000, maxTemperature=570000, minTemperature=320000, availableCapacity=340000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:17.399 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:17.468 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:18.254 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:18.254 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:18.254 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 33 38 31 39 39 31 31 36 2e 36 35 39 34 34 34 30 33 39 2e 35 32 31 32 35 34 30 37 32 2e 30 30 30 34 34 2e 33 36 30 30 30 30 30 30 35 31 36 30 30 30 31 34 30 30 30 32 31 38 33 39 30 30 30 30 44 33 30 37 30 31 30 2e 39 30 31 36 30 30 30 30 37 36 31 36 30 39 33 34 30 31 31 39 30 30 30 32 36 36 30 30 39 32 35 38 30 30 30 30 36 30 37 31 30 2e 34 31 30 30 30 30 32 30 30 30 30 30 31 30 34 30 30 30 30 33 34 32 30 30 30 33 30 30 30 33 30 30 30 31 35 30 30 30 30 30 30 30 30 30 30 34 35 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 bf 7E
2024-06-23 19:32:18.254 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142338199, longitude=116.6594440, latitude=39.5212540, speed=72.000, mileage=44.36000000, dischargeVoltage=516000, dischargeCurrent=14000, insulationResistance=218390000, gear=D, accelerationPedal=30, brakePedal=70, fuelConsumption=10.90, motorControllerTemperature=160000, motorSpeed=76160, motorTorque=9340, motorTemperature=119000, motorVoltage=26600, motorCurrent=92580000, powerBattery=60710., maxFeedbackPower=410000, maxDischargePower=200000, bmsSelfCheck=10, powerBatteryCurrent=40000, powerBatteryV3=342000, maxVoltage=3000, minVoltage=3000, maxTemperature=150000, minTemperature=000000, availableCapacity=450000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:18.256 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:18.257 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"30","availableCapacity":"450000","bmsSelfCheck":"10","brakePedal":"70","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"14000","dischargeVoltage":"516000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.90","gear":"D","insulationResistance":"218390000","latitude":"39.5212540","location":"1","longitude":"116.6594440","maxDischargePower":"200000","maxFeedbackPower":"410000","maxTemperature":"150000","maxVoltage":"3000","mcu":"1","mileage":"44.36000000","minTemperature":"000000","minVoltage":"3000","motorControllerTemperature":"160000","motorCurrent":"92580000","motorSpeed":"76160","motorTemperature":"119000","motorTorque":"9340","motorVoltage":"26600","powerBattery":"60710.","powerBatteryCurrent":"40000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"342000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142338199","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:18.257 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142338199, longitude=116.6594440, latitude=39.5212540, speed=72.000, mileage=44.36000000, dischargeVoltage=516000, dischargeCurrent=14000, insulationResistance=218390000, gear=D, accelerationPedal=30, brakePedal=70, fuelConsumption=10.90, motorControllerTemperature=160000, motorSpeed=76160, motorTorque=9340, motorTemperature=119000, motorVoltage=26600, motorCurrent=92580000, powerBattery=60710., maxFeedbackPower=410000, maxDischargePower=200000, bmsSelfCheck=10, powerBatteryCurrent=40000, powerBatteryV3=342000, maxVoltage=3000, minVoltage=3000, maxTemperature=150000, minTemperature=000000, availableCapacity=450000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:18.301 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:18.479 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:19.235 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:19.235 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:19.235 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 33 39 32 30 33 31 31 36 2e 36 36 30 36 39 39 30 33 39 2e 35 32 31 33 34 35 30 31 30 38 2e 30 30 34 34 2e 34 32 30 30 30 30 30 30 31 35 38 30 30 30 33 31 30 30 30 31 33 38 36 34 30 30 30 30 44 36 30 37 30 31 30 2e 36 30 31 34 30 30 30 30 36 37 36 32 39 35 33 32 30 36 33 30 30 30 30 32 31 39 30 30 31 32 32 31 33 30 30 30 36 30 36 39 39 2e 38 35 30 30 30 30 36 36 30 30 30 30 31 34 31 32 30 30 30 34 39 38 30 30 30 33 30 30 30 34 30 30 30 33 30 30 30 30 30 37 36 30 30 30 30 34 39 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 e3 7E
2024-06-23 19:32:19.235 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142339203, longitude=116.6606990, latitude=39.5213450, speed=108.00, mileage=44.42000000, dischargeVoltage=158000, dischargeCurrent=31000, insulationResistance=138640000, gear=D, accelerationPedal=60, brakePedal=70, fuelConsumption=10.60, motorControllerTemperature=140000, motorSpeed=67629, motorTorque=5320, motorTemperature=630000, motorVoltage=21900, motorCurrent=12213000, powerBattery=60699., maxFeedbackPower=850000, maxDischargePower=660000, bmsSelfCheck=14, powerBatteryCurrent=12000, powerBatteryV3=498000, maxVoltage=3000, minVoltage=4000, maxTemperature=300000, minTemperature=760000, availableCapacity=490000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:19.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:19.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"60","availableCapacity":"490000","bmsSelfCheck":"14","brakePedal":"70","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"31000","dischargeVoltage":"158000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.60","gear":"D","insulationResistance":"138640000","latitude":"39.5213450","location":"1","longitude":"116.6606990","maxDischargePower":"660000","maxFeedbackPower":"850000","maxTemperature":"300000","maxVoltage":"3000","mcu":"1","mileage":"44.42000000","minTemperature":"760000","minVoltage":"4000","motorControllerTemperature":"140000","motorCurrent":"12213000","motorSpeed":"67629","motorTemperature":"630000","motorTorque":"5320","motorVoltage":"21900","powerBattery":"60699.","powerBatteryCurrent":"12000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"498000","ptc":"1","runStatus":"0","soc":"1","speed":"108.00","timestamp":"1719142339203","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:19.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142339203, longitude=116.6606990, latitude=39.5213450, speed=108.00, mileage=44.42000000, dischargeVoltage=158000, dischargeCurrent=31000, insulationResistance=138640000, gear=D, accelerationPedal=60, brakePedal=70, fuelConsumption=10.60, motorControllerTemperature=140000, motorSpeed=67629, motorTorque=5320, motorTemperature=630000, motorVoltage=21900, motorCurrent=12213000, powerBattery=60699., maxFeedbackPower=850000, maxDischargePower=660000, bmsSelfCheck=14, powerBatteryCurrent=12000, powerBatteryV3=498000, maxVoltage=3000, minVoltage=4000, maxTemperature=300000, minTemperature=760000, availableCapacity=490000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:19.284 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:19.333 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:20.243 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:20.243 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:20.243 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 30 32 30 38 31 31 36 2e 36 36 31 31 30 37 30 33 39 2e 35 32 31 33 37 38 30 33 36 2e 30 30 30 34 34 2e 34 34 30 30 30 30 30 30 31 39 34 30 30 30 34 36 30 30 30 32 35 30 31 32 30 30 30 30 44 33 30 30 30 31 30 2e 33 30 36 31 30 30 30 30 34 35 38 35 33 34 39 32 30 36 38 30 30 30 30 31 37 38 30 30 32 37 39 32 30 30 30 30 36 30 36 39 39 2e 39 34 30 30 30 30 33 30 30 30 30 30 31 31 36 30 30 30 30 35 33 35 30 30 30 34 30 30 30 34 30 30 30 38 38 30 30 30 30 39 34 30 30 30 30 34 31 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 d1 7E
2024-06-23 19:32:20.243 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142340208, longitude=116.6611070, latitude=39.5213780, speed=36.000, mileage=44.44000000, dischargeVoltage=194000, dischargeCurrent=46000, insulationResistance=250120000, gear=D, accelerationPedal=30, brakePedal=00, fuelConsumption=10.30, motorControllerTemperature=610000, motorSpeed=45853, motorTorque=4920, motorTemperature=680000, motorVoltage=17800, motorCurrent=27920000, powerBattery=60699., maxFeedbackPower=940000, maxDischargePower=300000, bmsSelfCheck=11, powerBatteryCurrent=60000, powerBatteryV3=535000, maxVoltage=4000, minVoltage=4000, maxTemperature=880000, minTemperature=940000, availableCapacity=410000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:20.247 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:20.247 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"30","availableCapacity":"410000","bmsSelfCheck":"11","brakePedal":"00","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"46000","dischargeVoltage":"194000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.30","gear":"D","insulationResistance":"250120000","latitude":"39.5213780","location":"1","longitude":"116.6611070","maxDischargePower":"300000","maxFeedbackPower":"940000","maxTemperature":"880000","maxVoltage":"4000","mcu":"1","mileage":"44.44000000","minTemperature":"940000","minVoltage":"4000","motorControllerTemperature":"610000","motorCurrent":"27920000","motorSpeed":"45853","motorTemperature":"680000","motorTorque":"4920","motorVoltage":"17800","powerBattery":"60699.","powerBatteryCurrent":"60000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"535000","ptc":"1","runStatus":"0","soc":"1","speed":"36.000","timestamp":"1719142340208","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:20.247 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142340208, longitude=116.6611070, latitude=39.5213780, speed=36.000, mileage=44.44000000, dischargeVoltage=194000, dischargeCurrent=46000, insulationResistance=250120000, gear=D, accelerationPedal=30, brakePedal=00, fuelConsumption=10.30, motorControllerTemperature=610000, motorSpeed=45853, motorTorque=4920, motorTemperature=680000, motorVoltage=17800, motorCurrent=27920000, powerBattery=60699., maxFeedbackPower=940000, maxDischargePower=300000, bmsSelfCheck=11, powerBatteryCurrent=60000, powerBatteryV3=535000, maxVoltage=4000, minVoltage=4000, maxTemperature=880000, minTemperature=940000, availableCapacity=410000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:20.311 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:20.378 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:21.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:21.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:21.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 31 32 30 31 31 31 36 2e 36 36 32 30 39 39 30 33 39 2e 35 32 31 34 36 37 30 31 32 36 2e 30 30 34 34 2e 35 31 30 30 30 30 30 30 33 36 36 30 30 30 33 30 30 30 30 32 34 33 35 32 30 30 30 30 44 37 30 37 30 39 2e 37 30 30 35 33 30 30 30 30 33 38 37 34 36 36 35 37 30 31 35 30 30 30 30 32 38 32 30 30 36 37 37 32 30 30 30 30 36 30 36 39 30 2e 38 34 30 30 30 30 37 37 30 30 30 30 31 30 31 33 30 30 30 34 33 36 30 30 30 33 30 30 30 33 30 30 30 37 31 30 30 30 30 36 31 30 30 30 30 34 39 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 dd 7E
2024-06-23 19:32:21.236 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142341201, longitude=116.6620990, latitude=39.5214670, speed=126.00, mileage=44.51000000, dischargeVoltage=366000, dischargeCurrent=30000, insulationResistance=243520000, gear=D, accelerationPedal=70, brakePedal=70, fuelConsumption=9.700, motorControllerTemperature=530000, motorSpeed=38746, motorTorque=6570, motorTemperature=150000, motorVoltage=28200, motorCurrent=67720000, powerBattery=60690., maxFeedbackPower=840000, maxDischargePower=770000, bmsSelfCheck=10, powerBatteryCurrent=13000, powerBatteryV3=436000, maxVoltage=3000, minVoltage=3000, maxTemperature=710000, minTemperature=610000, availableCapacity=490000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:21.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:21.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"70","availableCapacity":"490000","bmsSelfCheck":"10","brakePedal":"70","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"30000","dischargeVoltage":"366000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"9.700","gear":"D","insulationResistance":"243520000","latitude":"39.5214670","location":"1","longitude":"116.6620990","maxDischargePower":"770000","maxFeedbackPower":"840000","maxTemperature":"710000","maxVoltage":"3000","mcu":"1","mileage":"44.51000000","minTemperature":"610000","minVoltage":"3000","motorControllerTemperature":"530000","motorCurrent":"67720000","motorSpeed":"38746","motorTemperature":"150000","motorTorque":"6570","motorVoltage":"28200","powerBattery":"60690.","powerBatteryCurrent":"13000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"436000","ptc":"1","runStatus":"0","soc":"1","speed":"126.00","timestamp":"1719142341201","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:21.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142341201, longitude=116.6620990, latitude=39.5214670, speed=126.00, mileage=44.51000000, dischargeVoltage=366000, dischargeCurrent=30000, insulationResistance=243520000, gear=D, accelerationPedal=70, brakePedal=70, fuelConsumption=9.700, motorControllerTemperature=530000, motorSpeed=38746, motorTorque=6570, motorTemperature=150000, motorVoltage=28200, motorCurrent=67720000, powerBattery=60690., maxFeedbackPower=840000, maxDischargePower=770000, bmsSelfCheck=10, powerBatteryCurrent=13000, powerBatteryV3=436000, maxVoltage=3000, minVoltage=3000, maxTemperature=710000, minTemperature=610000, availableCapacity=490000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:21.297 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:21.338 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:22.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:22.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:22.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 32 32 30 34 31 31 36 2e 36 36 33 33 31 38 30 33 39 2e 35 32 31 35 36 32 30 37 32 2e 30 30 30 34 34 2e 35 35 30 30 30 30 30 30 32 37 31 30 30 30 32 37 30 30 30 32 39 39 30 33 30 30 30 30 44 36 30 38 30 31 30 2e 38 30 35 30 30 30 30 30 37 35 33 39 36 34 31 33 30 30 30 30 30 30 30 32 39 36 30 30 32 35 30 30 30 30 30 30 36 30 36 39 30 2e 39 36 30 30 30 30 31 37 30 30 30 30 39 30 32 30 30 30 30 34 30 32 30 30 30 33 30 30 30 34 30 30 30 34 34 30 30 30 30 32 33 30 30 30 30 39 33 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 bc 7E
2024-06-23 19:32:22.237 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142342204, longitude=116.6633180, latitude=39.5215620, speed=72.000, mileage=44.55000000, dischargeVoltage=271000, dischargeCurrent=27000, insulationResistance=299030000, gear=D, accelerationPedal=60, brakePedal=80, fuelConsumption=10.80, motorControllerTemperature=500000, motorSpeed=75396, motorTorque=4130, motorTemperature=000000, motorVoltage=29600, motorCurrent=25000000, powerBattery=60690., maxFeedbackPower=960000, maxDischargePower=170000, bmsSelfCheck=90, powerBatteryCurrent=20000, powerBatteryV3=402000, maxVoltage=3000, minVoltage=4000, maxTemperature=440000, minTemperature=230000, availableCapacity=930000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:22.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:22.239 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"60","availableCapacity":"930000","bmsSelfCheck":"90","brakePedal":"80","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"27000","dischargeVoltage":"271000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.80","gear":"D","insulationResistance":"299030000","latitude":"39.5215620","location":"1","longitude":"116.6633180","maxDischargePower":"170000","maxFeedbackPower":"960000","maxTemperature":"440000","maxVoltage":"3000","mcu":"1","mileage":"44.55000000","minTemperature":"230000","minVoltage":"4000","motorControllerTemperature":"500000","motorCurrent":"25000000","motorSpeed":"75396","motorTemperature":"000000","motorTorque":"4130","motorVoltage":"29600","powerBattery":"60690.","powerBatteryCurrent":"20000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"402000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142342204","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:22.240 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142342204, longitude=116.6633180, latitude=39.5215620, speed=72.000, mileage=44.55000000, dischargeVoltage=271000, dischargeCurrent=27000, insulationResistance=299030000, gear=D, accelerationPedal=60, brakePedal=80, fuelConsumption=10.80, motorControllerTemperature=500000, motorSpeed=75396, motorTorque=4130, motorTemperature=000000, motorVoltage=29600, motorCurrent=25000000, powerBattery=60690., maxFeedbackPower=960000, maxDischargePower=170000, bmsSelfCheck=90, powerBatteryCurrent=20000, powerBatteryV3=402000, maxVoltage=3000, minVoltage=4000, maxTemperature=440000, minTemperature=230000, availableCapacity=930000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:22.276 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:22.318 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:23.228 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:23.228 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:23.228 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 33 31 39 35 31 31 36 2e 36 36 34 38 33 36 30 33 39 2e 35 32 31 36 37 30 30 31 30 38 2e 30 30 34 34 2e 36 31 30 30 30 30 30 30 35 38 33 30 30 30 34 31 30 30 30 31 31 38 31 39 30 30 30 30 44 38 30 35 30 31 31 2e 31 30 38 38 30 30 30 30 31 31 38 36 30 35 30 35 30 31 38 30 30 30 30 32 37 35 30 30 31 31 38 30 30 30 30 30 36 30 36 37 39 2e 34 31 30 30 30 30 31 30 30 30 30 30 31 31 32 30 30 30 30 36 35 33 30 30 30 33 30 30 30 34 30 30 30 32 36 30 30 30 30 32 34 30 30 30 30 37 34 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 c0 7E
2024-06-23 19:32:23.228 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142343195, longitude=116.6648360, latitude=39.5216700, speed=108.00, mileage=44.61000000, dischargeVoltage=583000, dischargeCurrent=41000, insulationResistance=118190000, gear=D, accelerationPedal=80, brakePedal=50, fuelConsumption=11.10, motorControllerTemperature=880000, motorSpeed=11860, motorTorque=5050, motorTemperature=180000, motorVoltage=27500, motorCurrent=11800000, powerBattery=60679., maxFeedbackPower=410000, maxDischargePower=100000, bmsSelfCheck=11, powerBatteryCurrent=20000, powerBatteryV3=653000, maxVoltage=3000, minVoltage=4000, maxTemperature=260000, minTemperature=240000, availableCapacity=740000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:23.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:23.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"80","availableCapacity":"740000","bmsSelfCheck":"11","brakePedal":"50","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"41000","dischargeVoltage":"583000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.10","gear":"D","insulationResistance":"118190000","latitude":"39.5216700","location":"1","longitude":"116.6648360","maxDischargePower":"100000","maxFeedbackPower":"410000","maxTemperature":"260000","maxVoltage":"3000","mcu":"1","mileage":"44.61000000","minTemperature":"240000","minVoltage":"4000","motorControllerTemperature":"880000","motorCurrent":"11800000","motorSpeed":"11860","motorTemperature":"180000","motorTorque":"5050","motorVoltage":"27500","powerBattery":"60679.","powerBatteryCurrent":"20000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"653000","ptc":"1","runStatus":"0","soc":"1","speed":"108.00","timestamp":"1719142343195","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:23.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142343195, longitude=116.6648360, latitude=39.5216700, speed=108.00, mileage=44.61000000, dischargeVoltage=583000, dischargeCurrent=41000, insulationResistance=118190000, gear=D, accelerationPedal=80, brakePedal=50, fuelConsumption=11.10, motorControllerTemperature=880000, motorSpeed=11860, motorTorque=5050, motorTemperature=180000, motorVoltage=27500, motorCurrent=11800000, powerBattery=60679., maxFeedbackPower=410000, maxDischargePower=100000, bmsSelfCheck=11, powerBatteryCurrent=20000, powerBatteryV3=653000, maxVoltage=3000, minVoltage=4000, maxTemperature=260000, minTemperature=240000, availableCapacity=740000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:23.281 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:23.337 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:24.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:24.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:24.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 34 31 39 34 31 31 36 2e 36 36 35 33 35 37 30 33 39 2e 35 32 31 37 36 35 30 35 34 2e 30 30 30 34 34 2e 36 34 30 30 30 30 30 30 36 34 33 30 30 30 32 37 30 30 30 33 37 38 38 30 30 30 30 30 44 33 30 33 30 31 31 2e 32 30 34 34 30 30 30 30 33 36 37 32 35 34 38 39 30 31 31 37 30 30 30 32 37 38 30 30 38 32 30 38 30 30 30 30 36 30 36 37 39 2e 35 36 30 30 30 30 36 31 30 30 30 30 36 30 36 30 30 30 30 35 32 38 30 30 30 34 30 30 30 33 30 30 30 32 30 30 30 30 30 31 34 30 30 30 30 32 38 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 ea 7E
2024-06-23 19:32:24.232 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142344194, longitude=116.6653570, latitude=39.5217650, speed=54.000, mileage=44.64000000, dischargeVoltage=643000, dischargeCurrent=27000, insulationResistance=378800000, gear=D, accelerationPedal=30, brakePedal=30, fuelConsumption=11.20, motorControllerTemperature=440000, motorSpeed=36725, motorTorque=4890, motorTemperature=117000, motorVoltage=27800, motorCurrent=82080000, powerBattery=60679., maxFeedbackPower=560000, maxDischargePower=610000, bmsSelfCheck=60, powerBatteryCurrent=60000, powerBatteryV3=528000, maxVoltage=4000, minVoltage=3000, maxTemperature=200000, minTemperature=140000, availableCapacity=280000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:24.236 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:24.236 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"30","availableCapacity":"280000","bmsSelfCheck":"60","brakePedal":"30","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"27000","dischargeVoltage":"643000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.20","gear":"D","insulationResistance":"378800000","latitude":"39.5217650","location":"1","longitude":"116.6653570","maxDischargePower":"610000","maxFeedbackPower":"560000","maxTemperature":"200000","maxVoltage":"4000","mcu":"1","mileage":"44.64000000","minTemperature":"140000","minVoltage":"3000","motorControllerTemperature":"440000","motorCurrent":"82080000","motorSpeed":"36725","motorTemperature":"117000","motorTorque":"4890","motorVoltage":"27800","powerBattery":"60679.","powerBatteryCurrent":"60000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"528000","ptc":"1","runStatus":"0","soc":"1","speed":"54.000","timestamp":"1719142344194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:24.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142344194, longitude=116.6653570, latitude=39.5217650, speed=54.000, mileage=44.64000000, dischargeVoltage=643000, dischargeCurrent=27000, insulationResistance=378800000, gear=D, accelerationPedal=30, brakePedal=30, fuelConsumption=11.20, motorControllerTemperature=440000, motorSpeed=36725, motorTorque=4890, motorTemperature=117000, motorVoltage=27800, motorCurrent=82080000, powerBattery=60679., maxFeedbackPower=560000, maxDischargePower=610000, bmsSelfCheck=60, powerBatteryCurrent=60000, powerBatteryV3=528000, maxVoltage=4000, minVoltage=3000, maxTemperature=200000, minTemperature=140000, availableCapacity=280000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:24.281 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:24.332 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:25.231 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:25.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:25.233 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 35 31 39 34 31 31 36 2e 36 36 36 33 39 37 30 33 39 2e 35 32 31 38 33 35 30 39 30 2e 30 30 30 34 34 2e 36 39 30 30 30 30 30 30 37 30 31 30 30 30 32 30 30 30 30 32 34 35 38 33 30 30 30 30 44 31 30 37 30 39 2e 39 30 30 36 31 30 30 30 30 39 36 35 38 31 31 39 37 30 31 33 38 30 30 30 32 34 32 30 30 31 34 33 34 35 30 30 30 36 30 36 36 39 2e 35 34 30 30 30 30 31 36 30 30 30 30 34 30 38 30 30 30 30 35 30 33 30 30 30 33 30 30 30 33 30 30 30 34 30 30 30 30 30 34 39 30 30 30 30 34 33 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 e9 7E
2024-06-23 19:32:25.233 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142345194, longitude=116.6663970, latitude=39.5218350, speed=90.000, mileage=44.69000000, dischargeVoltage=701000, dischargeCurrent=20000, insulationResistance=245830000, gear=D, accelerationPedal=10, brakePedal=70, fuelConsumption=9.900, motorControllerTemperature=610000, motorSpeed=96581, motorTorque=1970, motorTemperature=138000, motorVoltage=24200, motorCurrent=14345000, powerBattery=60669., maxFeedbackPower=540000, maxDischargePower=160000, bmsSelfCheck=40, powerBatteryCurrent=80000, powerBatteryV3=503000, maxVoltage=3000, minVoltage=3000, maxTemperature=400000, minTemperature=490000, availableCapacity=430000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:25.236 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:25.236 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"10","availableCapacity":"430000","bmsSelfCheck":"40","brakePedal":"70","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"20000","dischargeVoltage":"701000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"9.900","gear":"D","insulationResistance":"245830000","latitude":"39.5218350","location":"1","longitude":"116.6663970","maxDischargePower":"160000","maxFeedbackPower":"540000","maxTemperature":"400000","maxVoltage":"3000","mcu":"1","mileage":"44.69000000","minTemperature":"490000","minVoltage":"3000","motorControllerTemperature":"610000","motorCurrent":"14345000","motorSpeed":"96581","motorTemperature":"138000","motorTorque":"1970","motorVoltage":"24200","powerBattery":"60669.","powerBatteryCurrent":"80000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"503000","ptc":"1","runStatus":"0","soc":"1","speed":"90.000","timestamp":"1719142345194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:25.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142345194, longitude=116.6663970, latitude=39.5218350, speed=90.000, mileage=44.69000000, dischargeVoltage=701000, dischargeCurrent=20000, insulationResistance=245830000, gear=D, accelerationPedal=10, brakePedal=70, fuelConsumption=9.900, motorControllerTemperature=610000, motorSpeed=96581, motorTorque=1970, motorTemperature=138000, motorVoltage=24200, motorCurrent=14345000, powerBattery=60669., maxFeedbackPower=540000, maxDischargePower=160000, bmsSelfCheck=40, powerBatteryCurrent=80000, powerBatteryV3=503000, maxVoltage=3000, minVoltage=3000, maxTemperature=400000, minTemperature=490000, availableCapacity=430000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:25.282 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:25.322 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:26.240 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:26.240 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:26.240 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 36 31 39 36 31 31 36 2e 36 36 37 35 31 33 30 33 39 2e 35 32 31 39 31 38 30 37 32 2e 30 30 30 34 34 2e 37 33 30 30 30 30 30 30 31 32 30 30 30 30 33 30 30 30 30 34 35 34 32 30 30 30 30 30 44 37 30 34 30 39 2e 31 30 30 32 36 30 30 30 30 39 31 34 34 35 32 31 35 30 36 36 30 30 30 30 31 36 35 30 30 35 32 39 36 30 30 30 30 36 30 36 36 39 2e 37 35 30 30 30 30 33 32 30 30 30 30 37 30 31 33 30 30 30 35 33 36 30 30 30 33 30 30 30 34 30 30 30 34 30 30 30 30 30 34 36 30 30 30 30 38 34 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 d4 7E
2024-06-23 19:32:26.240 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142346196, longitude=116.6675130, latitude=39.5219180, speed=72.000, mileage=44.73000000, dischargeVoltage=120000, dischargeCurrent=30000, insulationResistance=454200000, gear=D, accelerationPedal=70, brakePedal=40, fuelConsumption=9.100, motorControllerTemperature=260000, motorSpeed=91445, motorTorque=2150, motorTemperature=660000, motorVoltage=16500, motorCurrent=52960000, powerBattery=60669., maxFeedbackPower=750000, maxDischargePower=320000, bmsSelfCheck=70, powerBatteryCurrent=13000, powerBatteryV3=536000, maxVoltage=3000, minVoltage=4000, maxTemperature=400000, minTemperature=460000, availableCapacity=840000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:26.244 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:26.244 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"70","availableCapacity":"840000","bmsSelfCheck":"70","brakePedal":"40","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"30000","dischargeVoltage":"120000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"9.100","gear":"D","insulationResistance":"454200000","latitude":"39.5219180","location":"1","longitude":"116.6675130","maxDischargePower":"320000","maxFeedbackPower":"750000","maxTemperature":"400000","maxVoltage":"3000","mcu":"1","mileage":"44.73000000","minTemperature":"460000","minVoltage":"4000","motorControllerTemperature":"260000","motorCurrent":"52960000","motorSpeed":"91445","motorTemperature":"660000","motorTorque":"2150","motorVoltage":"16500","powerBattery":"60669.","powerBatteryCurrent":"13000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"536000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142346196","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:26.244 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142346196, longitude=116.6675130, latitude=39.5219180, speed=72.000, mileage=44.73000000, dischargeVoltage=120000, dischargeCurrent=30000, insulationResistance=454200000, gear=D, accelerationPedal=70, brakePedal=40, fuelConsumption=9.100, motorControllerTemperature=260000, motorSpeed=91445, motorTorque=2150, motorTemperature=660000, motorVoltage=16500, motorCurrent=52960000, powerBattery=60669., maxFeedbackPower=750000, maxDischargePower=320000, bmsSelfCheck=70, powerBatteryCurrent=13000, powerBatteryV3=536000, maxVoltage=3000, minVoltage=4000, maxTemperature=400000, minTemperature=460000, availableCapacity=840000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:26.293 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:26.339 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:27.237 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:27.238 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:27.238 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 37 31 39 34 31 31 36 2e 36 36 38 34 37 39 30 33 39 2e 35 32 31 39 39 37 30 35 34 2e 30 30 30 34 34 2e 37 36 30 30 30 30 30 30 31 38 39 30 30 30 37 30 30 30 30 32 36 37 38 32 30 30 30 30 44 32 30 32 30 31 31 2e 36 30 36 31 30 30 30 30 37 30 35 39 39 37 37 39 30 31 32 33 30 30 30 31 34 37 30 30 37 34 39 37 30 30 30 30 36 30 36 36 39 2e 33 33 30 30 30 30 31 35 30 30 30 30 36 30 36 30 30 30 30 32 35 32 30 30 30 34 30 30 30 34 30 30 30 33 36 30 30 30 30 39 32 30 30 30 30 33 34 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 0a 7E
2024-06-23 19:32:27.238 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142347194, longitude=116.6684790, latitude=39.5219970, speed=54.000, mileage=44.76000000, dischargeVoltage=189000, dischargeCurrent=70000, insulationResistance=267820000, gear=D, accelerationPedal=20, brakePedal=20, fuelConsumption=11.60, motorControllerTemperature=610000, motorSpeed=70599, motorTorque=7790, motorTemperature=123000, motorVoltage=14700, motorCurrent=74970000, powerBattery=60669., maxFeedbackPower=330000, maxDischargePower=150000, bmsSelfCheck=60, powerBatteryCurrent=60000, powerBatteryV3=252000, maxVoltage=4000, minVoltage=4000, maxTemperature=360000, minTemperature=920000, availableCapacity=340000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:27.241 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:27.241 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"340000","bmsSelfCheck":"60","brakePedal":"20","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"70000","dischargeVoltage":"189000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.60","gear":"D","insulationResistance":"267820000","latitude":"39.5219970","location":"1","longitude":"116.6684790","maxDischargePower":"150000","maxFeedbackPower":"330000","maxTemperature":"360000","maxVoltage":"4000","mcu":"1","mileage":"44.76000000","minTemperature":"920000","minVoltage":"4000","motorControllerTemperature":"610000","motorCurrent":"74970000","motorSpeed":"70599","motorTemperature":"123000","motorTorque":"7790","motorVoltage":"14700","powerBattery":"60669.","powerBatteryCurrent":"60000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"252000","ptc":"1","runStatus":"0","soc":"1","speed":"54.000","timestamp":"1719142347194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:27.241 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142347194, longitude=116.6684790, latitude=39.5219970, speed=54.000, mileage=44.76000000, dischargeVoltage=189000, dischargeCurrent=70000, insulationResistance=267820000, gear=D, accelerationPedal=20, brakePedal=20, fuelConsumption=11.60, motorControllerTemperature=610000, motorSpeed=70599, motorTorque=7790, motorTemperature=123000, motorVoltage=14700, motorCurrent=74970000, powerBattery=60669., maxFeedbackPower=330000, maxDischargePower=150000, bmsSelfCheck=60, powerBatteryCurrent=60000, powerBatteryV3=252000, maxVoltage=4000, minVoltage=4000, maxTemperature=360000, minTemperature=920000, availableCapacity=340000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:27.305 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:27.363 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:28.229 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:28.230 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:28.230 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 38 31 39 34 31 31 36 2e 36 36 39 34 33 39 30 33 39 2e 35 32 32 30 37 35 30 35 34 2e 30 30 30 34 34 2e 37 39 30 30 30 30 30 30 33 32 39 30 30 30 32 34 30 30 30 31 36 38 31 34 30 30 30 30 44 38 30 32 30 31 30 2e 32 30 38 37 30 30 30 30 33 30 35 35 30 36 30 38 30 31 36 30 30 30 30 32 33 30 30 30 31 30 31 37 38 30 30 30 36 30 36 36 39 2e 32 31 30 30 30 30 36 31 30 30 30 30 33 30 31 30 30 30 30 37 34 35 30 30 30 34 30 30 30 33 30 30 30 32 32 30 30 30 30 35 39 30 30 30 30 32 39 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 d2 7E
2024-06-23 19:32:28.230 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142348194, longitude=116.6694390, latitude=39.5220750, speed=54.000, mileage=44.79000000, dischargeVoltage=329000, dischargeCurrent=24000, insulationResistance=168140000, gear=D, accelerationPedal=80, brakePedal=20, fuelConsumption=10.20, motorControllerTemperature=870000, motorSpeed=30550, motorTorque=6080, motorTemperature=160000, motorVoltage=23000, motorCurrent=10178000, powerBattery=60669., maxFeedbackPower=210000, maxDischargePower=610000, bmsSelfCheck=30, powerBatteryCurrent=10000, powerBatteryV3=745000, maxVoltage=4000, minVoltage=3000, maxTemperature=220000, minTemperature=590000, availableCapacity=290000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:28.232 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:28.232 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"80","availableCapacity":"290000","bmsSelfCheck":"30","brakePedal":"20","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"24000","dischargeVoltage":"329000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.20","gear":"D","insulationResistance":"168140000","latitude":"39.5220750","location":"1","longitude":"116.6694390","maxDischargePower":"610000","maxFeedbackPower":"210000","maxTemperature":"220000","maxVoltage":"4000","mcu":"1","mileage":"44.79000000","minTemperature":"590000","minVoltage":"3000","motorControllerTemperature":"870000","motorCurrent":"10178000","motorSpeed":"30550","motorTemperature":"160000","motorTorque":"6080","motorVoltage":"23000","powerBattery":"60669.","powerBatteryCurrent":"10000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"745000","ptc":"1","runStatus":"0","soc":"1","speed":"54.000","timestamp":"1719142348194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:28.232 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142348194, longitude=116.6694390, latitude=39.5220750, speed=54.000, mileage=44.79000000, dischargeVoltage=329000, dischargeCurrent=24000, insulationResistance=168140000, gear=D, accelerationPedal=80, brakePedal=20, fuelConsumption=10.20, motorControllerTemperature=870000, motorSpeed=30550, motorTorque=6080, motorTemperature=160000, motorVoltage=23000, motorCurrent=10178000, powerBattery=60669., maxFeedbackPower=210000, maxDischargePower=610000, bmsSelfCheck=30, powerBatteryCurrent=10000, powerBatteryV3=745000, maxVoltage=4000, minVoltage=3000, maxTemperature=220000, minTemperature=590000, availableCapacity=290000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:28.281 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:28.326 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:29.226 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:29.226 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:29.226 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 34 39 31 39 35 31 31 36 2e 36 37 30 31 39 30 30 33 39 2e 35 32 32 31 32 39 30 33 36 2e 30 30 30 34 34 2e 38 31 30 30 30 30 30 30 35 34 33 30 30 30 32 35 30 30 30 32 31 37 38 30 30 30 30 30 44 36 30 37 30 39 2e 38 30 30 32 37 30 30 30 30 39 32 36 38 36 34 38 39 30 31 34 34 30 30 30 31 36 31 30 30 37 37 39 31 30 30 30 30 36 30 36 36 39 2e 35 33 30 30 30 30 33 32 30 30 30 30 33 30 34 30 30 30 30 37 34 34 30 30 30 33 30 30 30 34 30 30 30 37 37 30 30 30 30 38 35 30 30 30 30 32 31 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 f2 7E
2024-06-23 19:32:29.226 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142349195, longitude=116.6701900, latitude=39.5221290, speed=36.000, mileage=44.81000000, dischargeVoltage=543000, dischargeCurrent=25000, insulationResistance=217800000, gear=D, accelerationPedal=60, brakePedal=70, fuelConsumption=9.800, motorControllerTemperature=270000, motorSpeed=92686, motorTorque=4890, motorTemperature=144000, motorVoltage=16100, motorCurrent=77910000, powerBattery=60669., maxFeedbackPower=530000, maxDischargePower=320000, bmsSelfCheck=30, powerBatteryCurrent=40000, powerBatteryV3=744000, maxVoltage=3000, minVoltage=4000, maxTemperature=770000, minTemperature=850000, availableCapacity=210000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:29.229 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:29.229 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"60","availableCapacity":"210000","bmsSelfCheck":"30","brakePedal":"70","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"25000","dischargeVoltage":"543000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"9.800","gear":"D","insulationResistance":"217800000","latitude":"39.5221290","location":"1","longitude":"116.6701900","maxDischargePower":"320000","maxFeedbackPower":"530000","maxTemperature":"770000","maxVoltage":"3000","mcu":"1","mileage":"44.81000000","minTemperature":"850000","minVoltage":"4000","motorControllerTemperature":"270000","motorCurrent":"77910000","motorSpeed":"92686","motorTemperature":"144000","motorTorque":"4890","motorVoltage":"16100","powerBattery":"60669.","powerBatteryCurrent":"40000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"744000","ptc":"1","runStatus":"0","soc":"1","speed":"36.000","timestamp":"1719142349195","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:29.229 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142349195, longitude=116.6701900, latitude=39.5221290, speed=36.000, mileage=44.81000000, dischargeVoltage=543000, dischargeCurrent=25000, insulationResistance=217800000, gear=D, accelerationPedal=60, brakePedal=70, fuelConsumption=9.800, motorControllerTemperature=270000, motorSpeed=92686, motorTorque=4890, motorTemperature=144000, motorVoltage=16100, motorCurrent=77910000, powerBattery=60669., maxFeedbackPower=530000, maxDischargePower=320000, bmsSelfCheck=30, powerBatteryCurrent=40000, powerBatteryV3=744000, maxVoltage=3000, minVoltage=4000, maxTemperature=770000, minTemperature=850000, availableCapacity=210000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:29.286 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:29.351 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:30.217 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:30.218 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:30.218 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 30 31 39 35 31 31 36 2e 36 37 31 33 38 32 30 33 39 2e 35 32 32 32 34 37 30 31 32 36 2e 30 30 34 34 2e 38 38 30 30 30 30 30 30 35 39 39 30 30 30 33 30 30 30 30 31 32 32 31 33 30 30 30 30 44 31 30 36 30 31 31 2e 30 30 31 30 30 30 30 30 36 34 39 35 32 33 36 30 30 35 33 30 30 30 30 32 32 34 30 30 31 32 35 30 30 30 30 30 36 30 36 35 38 2e 35 33 30 30 30 30 38 30 30 30 30 30 37 30 31 34 30 30 30 36 33 37 30 30 30 33 30 30 30 33 30 30 30 36 32 30 30 30 30 32 32 30 30 30 30 39 32 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 b4 7E
2024-06-23 19:32:30.218 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142350195, longitude=116.6713820, latitude=39.5222470, speed=126.00, mileage=44.88000000, dischargeVoltage=599000, dischargeCurrent=30000, insulationResistance=122130000, gear=D, accelerationPedal=10, brakePedal=60, fuelConsumption=11.00, motorControllerTemperature=100000, motorSpeed=64952, motorTorque=3600, motorTemperature=530000, motorVoltage=22400, motorCurrent=12500000, powerBattery=60658., maxFeedbackPower=530000, maxDischargePower=800000, bmsSelfCheck=70, powerBatteryCurrent=14000, powerBatteryV3=637000, maxVoltage=3000, minVoltage=3000, maxTemperature=620000, minTemperature=220000, availableCapacity=920000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:30.220 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:30.220 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"10","availableCapacity":"920000","bmsSelfCheck":"70","brakePedal":"60","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"30000","dischargeVoltage":"599000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.00","gear":"D","insulationResistance":"122130000","latitude":"39.5222470","location":"1","longitude":"116.6713820","maxDischargePower":"800000","maxFeedbackPower":"530000","maxTemperature":"620000","maxVoltage":"3000","mcu":"1","mileage":"44.88000000","minTemperature":"220000","minVoltage":"3000","motorControllerTemperature":"100000","motorCurrent":"12500000","motorSpeed":"64952","motorTemperature":"530000","motorTorque":"3600","motorVoltage":"22400","powerBattery":"60658.","powerBatteryCurrent":"14000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"637000","ptc":"1","runStatus":"0","soc":"1","speed":"126.00","timestamp":"1719142350195","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:30.221 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142350195, longitude=116.6713820, latitude=39.5222470, speed=126.00, mileage=44.88000000, dischargeVoltage=599000, dischargeCurrent=30000, insulationResistance=122130000, gear=D, accelerationPedal=10, brakePedal=60, fuelConsumption=11.00, motorControllerTemperature=100000, motorSpeed=64952, motorTorque=3600, motorTemperature=530000, motorVoltage=22400, motorCurrent=12500000, powerBattery=60658., maxFeedbackPower=530000, maxDischargePower=800000, bmsSelfCheck=70, powerBatteryCurrent=14000, powerBatteryV3=637000, maxVoltage=3000, minVoltage=3000, maxTemperature=620000, minTemperature=220000, availableCapacity=920000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:30.282 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:30.333 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:31.234 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:31.234 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:31.234 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 31 31 39 34 31 31 36 2e 36 37 32 31 31 37 30 33 39 2e 35 32 32 32 32 36 30 33 36 2e 30 30 30 34 34 2e 39 30 30 30 30 30 30 30 37 34 36 30 30 30 36 30 30 30 30 33 36 33 36 30 30 30 30 30 44 31 30 35 30 31 31 2e 33 30 33 38 30 30 30 30 35 37 39 30 34 38 38 33 30 31 33 31 30 30 30 32 39 32 30 30 31 32 38 34 30 30 30 30 36 30 36 35 38 2e 36 37 30 30 30 30 34 35 30 30 30 30 32 30 37 30 30 30 30 32 35 30 30 30 30 33 30 30 30 34 30 30 30 38 33 30 30 30 30 33 38 30 30 30 30 35 37 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 d1 7E
2024-06-23 19:32:31.234 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142351194, longitude=116.6721170, latitude=39.5222260, speed=36.000, mileage=44.90000000, dischargeVoltage=746000, dischargeCurrent=60000, insulationResistance=363600000, gear=D, accelerationPedal=10, brakePedal=50, fuelConsumption=11.30, motorControllerTemperature=380000, motorSpeed=57904, motorTorque=8830, motorTemperature=131000, motorVoltage=29200, motorCurrent=12840000, powerBattery=60658., maxFeedbackPower=670000, maxDischargePower=450000, bmsSelfCheck=20, powerBatteryCurrent=70000, powerBatteryV3=250000, maxVoltage=3000, minVoltage=4000, maxTemperature=830000, minTemperature=380000, availableCapacity=570000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:31.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:31.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"10","availableCapacity":"570000","bmsSelfCheck":"20","brakePedal":"50","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"60000","dischargeVoltage":"746000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.30","gear":"D","insulationResistance":"363600000","latitude":"39.5222260","location":"1","longitude":"116.6721170","maxDischargePower":"450000","maxFeedbackPower":"670000","maxTemperature":"830000","maxVoltage":"3000","mcu":"1","mileage":"44.90000000","minTemperature":"380000","minVoltage":"4000","motorControllerTemperature":"380000","motorCurrent":"12840000","motorSpeed":"57904","motorTemperature":"131000","motorTorque":"8830","motorVoltage":"29200","powerBattery":"60658.","powerBatteryCurrent":"70000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"250000","ptc":"1","runStatus":"0","soc":"1","speed":"36.000","timestamp":"1719142351194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:31.237 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142351194, longitude=116.6721170, latitude=39.5222260, speed=36.000, mileage=44.90000000, dischargeVoltage=746000, dischargeCurrent=60000, insulationResistance=363600000, gear=D, accelerationPedal=10, brakePedal=50, fuelConsumption=11.30, motorControllerTemperature=380000, motorSpeed=57904, motorTorque=8830, motorTemperature=131000, motorVoltage=29200, motorCurrent=12840000, powerBattery=60658., maxFeedbackPower=670000, maxDischargePower=450000, bmsSelfCheck=20, powerBatteryCurrent=70000, powerBatteryV3=250000, maxVoltage=3000, minVoltage=4000, maxTemperature=830000, minTemperature=380000, availableCapacity=570000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:31.300 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:31.341 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:32.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:32.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:32.232 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 32 31 39 35 31 31 36 2e 36 37 33 30 31 39 30 33 39 2e 35 32 32 33 32 31 30 37 32 2e 30 30 30 34 34 2e 39 34 30 30 30 30 30 30 35 37 35 30 30 30 37 30 30 30 30 38 38 33 34 30 30 30 30 30 44 30 30 38 30 39 2e 34 30 30 36 35 30 30 30 30 38 37 30 30 39 34 37 38 30 35 36 30 30 30 30 32 39 39 30 30 36 36 36 32 30 30 30 30 36 30 36 35 38 2e 37 35 30 30 30 30 34 38 30 30 30 30 31 32 31 33 30 30 30 34 31 37 30 30 30 33 30 30 30 34 30 30 30 39 30 30 30 30 30 32 35 30 30 30 30 32 35 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 f0 7E
2024-06-23 19:32:32.232 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142352195, longitude=116.6730190, latitude=39.5223210, speed=72.000, mileage=44.94000000, dischargeVoltage=575000, dischargeCurrent=70000, insulationResistance=883400000, gear=D, accelerationPedal=00, brakePedal=80, fuelConsumption=9.400, motorControllerTemperature=650000, motorSpeed=87009, motorTorque=4780, motorTemperature=560000, motorVoltage=29900, motorCurrent=66620000, powerBattery=60658., maxFeedbackPower=750000, maxDischargePower=480000, bmsSelfCheck=12, powerBatteryCurrent=13000, powerBatteryV3=417000, maxVoltage=3000, minVoltage=4000, maxTemperature=900000, minTemperature=250000, availableCapacity=250000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:32.235 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:32.235 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"00","availableCapacity":"250000","bmsSelfCheck":"12","brakePedal":"80","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"70000","dischargeVoltage":"575000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"9.400","gear":"D","insulationResistance":"883400000","latitude":"39.5223210","location":"1","longitude":"116.6730190","maxDischargePower":"480000","maxFeedbackPower":"750000","maxTemperature":"900000","maxVoltage":"3000","mcu":"1","mileage":"44.94000000","minTemperature":"250000","minVoltage":"4000","motorControllerTemperature":"650000","motorCurrent":"66620000","motorSpeed":"87009","motorTemperature":"560000","motorTorque":"4780","motorVoltage":"29900","powerBattery":"60658.","powerBatteryCurrent":"13000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"417000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142352195","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:32.236 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142352195, longitude=116.6730190, latitude=39.5223210, speed=72.000, mileage=44.94000000, dischargeVoltage=575000, dischargeCurrent=70000, insulationResistance=883400000, gear=D, accelerationPedal=00, brakePedal=80, fuelConsumption=9.400, motorControllerTemperature=650000, motorSpeed=87009, motorTorque=4780, motorTemperature=560000, motorVoltage=29900, motorCurrent=66620000, powerBattery=60658., maxFeedbackPower=750000, maxDischargePower=480000, bmsSelfCheck=12, powerBatteryCurrent=13000, powerBatteryV3=417000, maxVoltage=3000, minVoltage=4000, maxTemperature=900000, minTemperature=250000, availableCapacity=250000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:32.281 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:32.322 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:33.222 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:33.222 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:33.223 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 33 31 39 34 31 31 36 2e 36 37 33 36 36 32 30 33 39 2e 35 32 32 33 36 33 30 33 36 2e 30 30 30 34 34 2e 39 36 30 30 30 30 30 30 33 35 35 30 30 30 38 30 30 30 30 32 39 33 35 35 30 30 30 30 44 33 30 30 30 31 31 2e 39 30 35 30 30 30 30 30 31 34 30 30 30 33 39 36 30 32 31 30 30 30 30 32 36 38 30 30 31 30 38 36 32 30 30 30 36 30 36 35 38 2e 37 35 30 30 30 30 32 39 30 30 30 30 30 30 34 30 30 30 30 34 39 31 30 30 30 34 30 30 30 34 30 30 30 38 37 30 30 30 30 32 33 30 30 30 30 32 34 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 cc 7E
2024-06-23 19:32:33.223 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142353194, longitude=116.6736620, latitude=39.5223630, speed=36.000, mileage=44.96000000, dischargeVoltage=355000, dischargeCurrent=80000, insulationResistance=293550000, gear=D, accelerationPedal=30, brakePedal=00, fuelConsumption=11.90, motorControllerTemperature=500000, motorSpeed=14000, motorTorque=3960, motorTemperature=210000, motorVoltage=26800, motorCurrent=10862000, powerBattery=60658., maxFeedbackPower=750000, maxDischargePower=290000, bmsSelfCheck=00, powerBatteryCurrent=40000, powerBatteryV3=491000, maxVoltage=4000, minVoltage=4000, maxTemperature=870000, minTemperature=230000, availableCapacity=240000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:33.225 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:33.225 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"30","availableCapacity":"240000","bmsSelfCheck":"00","brakePedal":"00","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"80000","dischargeVoltage":"355000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.90","gear":"D","insulationResistance":"293550000","latitude":"39.5223630","location":"1","longitude":"116.6736620","maxDischargePower":"290000","maxFeedbackPower":"750000","maxTemperature":"870000","maxVoltage":"4000","mcu":"1","mileage":"44.96000000","minTemperature":"230000","minVoltage":"4000","motorControllerTemperature":"500000","motorCurrent":"10862000","motorSpeed":"14000","motorTemperature":"210000","motorTorque":"3960","motorVoltage":"26800","powerBattery":"60658.","powerBatteryCurrent":"40000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"491000","ptc":"1","runStatus":"0","soc":"1","speed":"36.000","timestamp":"1719142353194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:33.225 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142353194, longitude=116.6736620, latitude=39.5223630, speed=36.000, mileage=44.96000000, dischargeVoltage=355000, dischargeCurrent=80000, insulationResistance=293550000, gear=D, accelerationPedal=30, brakePedal=00, fuelConsumption=11.90, motorControllerTemperature=500000, motorSpeed=14000, motorTorque=3960, motorTemperature=210000, motorVoltage=26800, motorCurrent=10862000, powerBattery=60658., maxFeedbackPower=750000, maxDischargePower=290000, bmsSelfCheck=00, powerBatteryCurrent=40000, powerBatteryV3=491000, maxVoltage=4000, minVoltage=4000, maxTemperature=870000, minTemperature=230000, availableCapacity=240000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:33.260 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:33.303 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:34.228 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:34.228 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:34.228 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 34 31 39 34 31 31 36 2e 36 37 34 34 32 31 30 33 39 2e 35 32 32 34 32 30 30 35 34 2e 30 30 30 34 34 2e 39 39 30 30 30 30 30 30 36 30 32 30 30 30 32 39 30 30 30 39 33 35 38 30 30 30 30 30 44 38 30 35 30 31 30 2e 35 30 33 39 30 30 30 30 37 37 30 33 30 35 30 36 30 36 36 30 30 30 30 32 35 31 30 30 33 30 36 34 30 30 30 30 36 30 36 35 38 2e 36 34 30 30 30 30 37 33 30 30 30 30 35 30 31 31 30 30 30 34 35 30 30 30 30 33 30 30 30 33 30 30 30 39 39 30 30 30 30 31 38 30 30 30 30 38 37 30 30 30 30 30 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 da 7E
2024-06-23 19:32:34.229 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142354194, longitude=116.6744210, latitude=39.5224200, speed=54.000, mileage=44.99000000, dischargeVoltage=602000, dischargeCurrent=29000, insulationResistance=935800000, gear=D, accelerationPedal=80, brakePedal=50, fuelConsumption=10.50, motorControllerTemperature=390000, motorSpeed=77030, motorTorque=5060, motorTemperature=660000, motorVoltage=25100, motorCurrent=30640000, powerBattery=60658., maxFeedbackPower=640000, maxDischargePower=730000, bmsSelfCheck=50, powerBatteryCurrent=11000, powerBatteryV3=450000, maxVoltage=3000, minVoltage=3000, maxTemperature=990000, minTemperature=180000, availableCapacity=870000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:34.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:34.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"80","availableCapacity":"870000","bmsSelfCheck":"50","brakePedal":"50","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"29000","dischargeVoltage":"602000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"10.50","gear":"D","insulationResistance":"935800000","latitude":"39.5224200","location":"1","longitude":"116.6744210","maxDischargePower":"730000","maxFeedbackPower":"640000","maxTemperature":"990000","maxVoltage":"3000","mcu":"1","mileage":"44.99000000","minTemperature":"180000","minVoltage":"3000","motorControllerTemperature":"390000","motorCurrent":"30640000","motorSpeed":"77030","motorTemperature":"660000","motorTorque":"5060","motorVoltage":"25100","powerBattery":"60658.","powerBatteryCurrent":"11000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"450000","ptc":"1","runStatus":"0","soc":"1","speed":"54.000","timestamp":"1719142354194","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:34.231 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142354194, longitude=116.6744210, latitude=39.5224200, speed=54.000, mileage=44.99000000, dischargeVoltage=602000, dischargeCurrent=29000, insulationResistance=935800000, gear=D, accelerationPedal=80, brakePedal=50, fuelConsumption=10.50, motorControllerTemperature=390000, motorSpeed=77030, motorTorque=5060, motorTemperature=660000, motorVoltage=25100, motorCurrent=30640000, powerBattery=60658., maxFeedbackPower=640000, maxDischargePower=730000, bmsSelfCheck=50, powerBatteryCurrent=11000, powerBatteryV3=450000, maxVoltage=3000, minVoltage=3000, maxTemperature=990000, minTemperature=180000, availableCapacity=870000, vehicleStatus=0, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:34.286 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:244 - 该车故障GZ001信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:34.331 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:309 - 该车故障GZ003信息在Redis中的过期时间被刷新，不发送到RabbitMQ
2024-06-23 19:32:35.235 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:35.235 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:35.236 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 35 31 39 34 31 31 36 2e 36 37 35 35 36 39 30 33 39 2e 35 32 32 35 32 34 30 37 32 2e 30 30 30 34 35 2e 30 33 30 30 30 30 30 30 31 33 35 30 30 30 31 32 30 30 30 31 30 34 34 37 30 30 30 30 44 32 30 33 30 31 31 2e 33 30 31 38 30 30 30 30 39 32 33 37 34 36 34 38 30 35 32 30 30 30 30 31 38 33 30 30 31 33 37 34 38 30 30 30 36 30 36 35 38 2e 33 34 30 30 30 30 35 35 30 30 30 30 33 30 38 30 30 30 30 32 37 34 30 30 30 34 30 30 30 33 30 30 30 36 31 30 30 30 30 31 37 30 30 30 30 36 35 30 30 30 30 31 31 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 d3 7E
2024-06-23 19:32:35.236 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142355194, longitude=116.6755690, latitude=39.5225240, speed=72.000, mileage=45.03000000, dischargeVoltage=135000, dischargeCurrent=12000, insulationResistance=104470000, gear=D, accelerationPedal=20, brakePedal=30, fuelConsumption=11.30, motorControllerTemperature=180000, motorSpeed=92374, motorTorque=6480, motorTemperature=520000, motorVoltage=18300, motorCurrent=13748000, powerBattery=60658., maxFeedbackPower=340000, maxDischargePower=550000, bmsSelfCheck=30, powerBatteryCurrent=80000, powerBatteryV3=274000, maxVoltage=4000, minVoltage=3000, maxTemperature=610000, minTemperature=170000, availableCapacity=650000, vehicleStatus=1, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:35.238 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:35.238 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"650000","bmsSelfCheck":"30","brakePedal":"30","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"12000","dischargeVoltage":"135000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.30","gear":"D","insulationResistance":"104470000","latitude":"39.5225240","location":"1","longitude":"116.6755690","maxDischargePower":"550000","maxFeedbackPower":"340000","maxTemperature":"610000","maxVoltage":"4000","mcu":"1","mileage":"45.03000000","minTemperature":"170000","minVoltage":"3000","motorControllerTemperature":"180000","motorCurrent":"13748000","motorSpeed":"92374","motorTemperature":"520000","motorTorque":"6480","motorVoltage":"18300","powerBattery":"60658.","powerBatteryCurrent":"80000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"274000","ptc":"1","runStatus":"0","soc":"1","speed":"72.000","timestamp":"1719142355194","vehicleStatus":"1","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:35.238 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142355194, longitude=116.6755690, latitude=39.5225240, speed=72.000, mileage=45.03000000, dischargeVoltage=135000, dischargeCurrent=12000, insulationResistance=104470000, gear=D, accelerationPedal=20, brakePedal=30, fuelConsumption=11.30, motorControllerTemperature=180000, motorSpeed=92374, motorTorque=6480, motorTemperature=520000, motorVoltage=18300, motorCurrent=13748000, powerBattery=60658., maxFeedbackPower=340000, maxDischargePower=550000, bmsSelfCheck=30, powerBatteryCurrent=80000, powerBatteryV3=274000, maxVoltage=4000, minVoltage=3000, maxTemperature=610000, minTemperature=170000, availableCapacity=650000, vehicleStatus=1, chargeStatus=1, runStatus=0, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:36.238 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:32:36.238 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:32:36.238 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 33 35 36 31 39 33 31 31 36 2e 36 37 36 36 31 30 30 33 39 2e 35 32 32 36 31 35 30 31 30 38 2e 30 30 34 35 2e 30 39 30 30 30 30 30 30 37 32 32 30 30 30 32 36 30 30 30 32 36 33 38 39 30 30 30 30 44 32 30 39 30 39 2e 35 30 30 37 36 30 30 30 30 34 32 34 35 35 35 37 37 30 38 31 30 30 30 30 31 31 37 30 30 31 34 37 38 37 30 30 30 36 30 36 34 38 2e 37 38 30 30 30 30 31 31 30 30 30 30 36 30 31 30 30 30 30 32 32 39 30 30 30 34 30 30 30 33 30 30 30 38 30 30 30 30 30 31 38 30 30 30 30 39 37 30 30 30 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 f6 7E
2024-06-23 19:32:36.238 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142356193, longitude=116.6766100, latitude=39.5226150, speed=108.00, mileage=45.09000000, dischargeVoltage=722000, dischargeCurrent=26000, insulationResistance=263890000, gear=D, accelerationPedal=20, brakePedal=90, fuelConsumption=9.500, motorControllerTemperature=760000, motorSpeed=42455, motorTorque=5770, motorTemperature=810000, motorVoltage=11700, motorCurrent=14787000, powerBattery=60648., maxFeedbackPower=780000, maxDischargePower=110000, bmsSelfCheck=60, powerBatteryCurrent=10000, powerBatteryV3=229000, maxVoltage=4000, minVoltage=3000, maxTemperature=800000, minTemperature=180000, availableCapacity=970000, vehicleStatus=1, chargeStatus=1, runStatus=1, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:36.241 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:32:36.241 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"970000","bmsSelfCheck":"60","brakePedal":"90","chargeStatus":"1","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"26000","dischargeVoltage":"722000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"9.500","gear":"D","insulationResistance":"263890000","latitude":"39.5226150","location":"1","longitude":"116.6766100","maxDischargePower":"110000","maxFeedbackPower":"780000","maxTemperature":"800000","maxVoltage":"4000","mcu":"1","mileage":"45.09000000","minTemperature":"180000","minVoltage":"3000","motorControllerTemperature":"760000","motorCurrent":"14787000","motorSpeed":"42455","motorTemperature":"810000","motorTorque":"5770","motorVoltage":"11700","powerBattery":"60648.","powerBatteryCurrent":"10000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"229000","ptc":"1","runStatus":"1","soc":"1","speed":"108.00","timestamp":"1719142356193","vehicleStatus":"1","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:32:36.241 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142356193, longitude=116.6766100, latitude=39.5226150, speed=108.00, mileage=45.09000000, dischargeVoltage=722000, dischargeCurrent=26000, insulationResistance=263890000, gear=D, accelerationPedal=20, brakePedal=90, fuelConsumption=9.500, motorControllerTemperature=760000, motorSpeed=42455, motorTorque=5770, motorTemperature=810000, motorVoltage=11700, motorCurrent=14787000, powerBattery=60648., maxFeedbackPower=780000, maxDischargePower=110000, bmsSelfCheck=60, powerBatteryCurrent=10000, powerBatteryV3=229000, maxVoltage=4000, minVoltage=3000, maxTemperature=800000, minTemperature=180000, availableCapacity=970000, vehicleStatus=1, chargeStatus=1, runStatus=1, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:32:44.361 [container-3] INFO  com.muyu.event.redis.RedisKeyExpirationListener:39 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ001
2024-06-23 19:32:44.362 [container-3] INFO  com.muyu.event.redis.RedisKeyExpirationListener:43 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ001
2024-06-23 19:32:44.361 [container-2] INFO  com.muyu.event.redis.RedisKeyExpirationListener:39 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ003
2024-06-23 19:32:44.362 [container-2] INFO  com.muyu.event.redis.RedisKeyExpirationListener:43 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ003
2024-06-23 19:34:05.984 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:46 - topic:test1
2024-06-23 19:34:05.984 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:47 - Qos:0
2024-06-23 19:34:05.984 [MQTT Call: protocol-parsing] INFO  com.muyu.mqtt.MessageCallbackService:48 - message content:7E 5a 45 51 41 36 56 32 5a 39 38 4d 39 5a 4d 46 5a 46 31 37 31 39 31 34 32 34 34 35 39 33 32 31 31 36 2e 36 37 37 38 32 37 30 33 39 2e 35 32 32 37 30 36 30 31 32 36 2e 30 30 34 35 2e 31 36 30 30 30 30 30 30 34 34 37 30 30 30 31 38 30 30 30 31 39 32 32 33 30 30 30 30 44 32 30 34 30 31 31 2e 30 30 32 37 30 30 30 30 39 35 35 39 37 33 33 32 30 34 32 30 30 30 30 32 33 30 30 30 36 30 32 33 30 30 30 30 36 30 36 33 37 2e 36 30 30 30 30 30 34 31 30 30 30 30 39 30 31 30 30 30 30 35 33 37 30 30 30 33 30 30 30 33 30 30 30 34 39 30 30 30 30 34 33 30 30 30 30 33 33 30 30 30 30 30 30 31 31 31 31 31 31 31 31 31 31 31 31 31 31 31 c5 7E
2024-06-23 19:34:05.984 [MQTT Call: protocol-parsing] ERROR com.muyu.utils.ConversionUtil:323 - 报文解析:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142445932, longitude=116.6778270, latitude=39.5227060, speed=126.00, mileage=45.16000000, dischargeVoltage=447000, dischargeCurrent=18000, insulationResistance=192230000, gear=D, accelerationPedal=20, brakePedal=40, fuelConsumption=11.00, motorControllerTemperature=270000, motorSpeed=95597, motorTorque=3320, motorTemperature=420000, motorVoltage=23000, motorCurrent=60230000, powerBattery=60637., maxFeedbackPower=600000, maxDischargePower=410000, bmsSelfCheck=90, powerBatteryCurrent=10000, powerBatteryV3=537000, maxVoltage=3000, minVoltage=3000, maxTemperature=490000, minTemperature=430000, availableCapacity=330000, vehicleStatus=0, chargeStatus=0, runStatus=1, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:34:05.986 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:50 - 开始消费
2024-06-23 19:34:05.986 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:54 - value:{"abs":"1","accelerationPedal":"20","availableCapacity":"330000","bmsSelfCheck":"90","brakePedal":"40","chargeStatus":"0","chargeWorkStatus":"1","chg":"1","dcdc":"1","dischargeCurrent":"18000","dischargeVoltage":"447000","driveMotorStatus":"1","eas":"1","eps":"1","fuelConsumption":"11.00","gear":"D","insulationResistance":"192230000","latitude":"39.5227060","location":"1","longitude":"116.6778270","maxDischargePower":"410000","maxFeedbackPower":"600000","maxTemperature":"490000","maxVoltage":"3000","mcu":"1","mileage":"45.16000000","minTemperature":"430000","minVoltage":"3000","motorControllerTemperature":"270000","motorCurrent":"60230000","motorSpeed":"95597","motorTemperature":"420000","motorTorque":"3320","motorVoltage":"23000","powerBattery":"60637.","powerBatteryCurrent":"10000","powerBatteryCurrentStatus":"1","powerBatteryHeat":"1","powerBatteryHeating":"1","powerBatteryV3":"537000","ptc":"1","runStatus":"1","soc":"1","speed":"126.00","timestamp":"1719142445932","vehicleStatus":"0","vin":"ZEQA6V2Z98M9ZMFZF"}
2024-06-23 19:34:05.986 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  com.muyu.kafka.SimpleKafkaConsumer:56 - messageData1:MessageData(vin=ZEQA6V2Z98M9ZMFZF, timestamp=1719142445932, longitude=116.6778270, latitude=39.5227060, speed=126.00, mileage=45.16000000, dischargeVoltage=447000, dischargeCurrent=18000, insulationResistance=192230000, gear=D, accelerationPedal=20, brakePedal=40, fuelConsumption=11.00, motorControllerTemperature=270000, motorSpeed=95597, motorTorque=3320, motorTemperature=420000, motorVoltage=23000, motorCurrent=60230000, powerBattery=60637., maxFeedbackPower=600000, maxDischargePower=410000, bmsSelfCheck=90, powerBatteryCurrent=10000, powerBatteryV3=537000, maxVoltage=3000, minVoltage=3000, maxTemperature=490000, minTemperature=430000, availableCapacity=330000, vehicleStatus=0, chargeStatus=0, runStatus=1, soc=1, chargeWorkStatus=1, driveMotorStatus=1, location=1, eas=1, ptc=1, eps=1, abs=1, mcu=1, powerBatteryHeating=1, powerBatteryCurrentStatus=1, powerBatteryHeat=1, dcdc=1, chg=1)
2024-06-23 19:34:06.043 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:755 - 故障信息ZEQA6V2Z98M9ZMFZF发送到RabbitMQ
2024-06-23 19:34:06.043 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:239 - 该车故障GZ001信息首次存储到本地缓存和Redis中，并发送到RabbitMQ
2024-06-23 19:34:06.096 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:755 - 故障信息ZEQA6V2Z98M9ZMFZF发送到RabbitMQ
2024-06-23 19:34:06.096 [Thread-1] INFO  com.muyu.event.service.impl.EventServiceImpl:271 - 该车故障GZ002信息首次存储到本地缓存和Redis中，并发送到RabbitMQ
2024-06-23 19:34:16.071 [container-4] INFO  com.muyu.event.redis.RedisKeyExpirationListener:39 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ001
2024-06-23 19:34:16.071 [container-4] INFO  com.muyu.event.redis.RedisKeyExpirationListener:43 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ001
2024-06-23 19:34:16.145 [container-5] INFO  com.muyu.event.redis.RedisKeyExpirationListener:39 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ002
2024-06-23 19:34:16.145 [container-5] INFO  com.muyu.event.redis.RedisKeyExpirationListener:43 - 过期redis数据：ZEQA6V2Z98M9ZMFZF-GZ002
2024-06-23 19:39:41.817 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-2] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:649 - Waiting for workers to finish.
2024-06-23 19:39:41.843 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#1-2] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:649 - Waiting for workers to finish.
2024-06-23 19:39:41.862 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#2-2] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:649 - Waiting for workers to finish.
2024-06-23 19:39:42.108 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#1-2] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:653 - Successfully waited for workers to finish.
2024-06-23 19:39:42.293 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#2-2] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:653 - Successfully waited for workers to finish.
2024-06-23 19:39:42.824 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-2] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:653 - Successfully waited for workers to finish.
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.ConsumerCoordinator:307 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Revoke previously assigned partitions test1-0
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:1042 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Member consumer-Topics-3-42c1551e-fd1c-4369-a50e-f5dc3675107d sending LeaveGroup request to coordinator xiaoxin:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:1042 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Member consumer-Topics-4-939348d8-793b-4f8d-93e5-a84a9d797463 sending LeaveGroup request to coordinator xiaoxin:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: partitions revoked: [test1-0]
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.a.k.c.consumer.internals.AbstractCoordinator:1042 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Member consumer-Topics-2-ed640a93-b361-4e22-8b0e-493467238c44 sending LeaveGroup request to coordinator xiaoxin:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:1074 - [Consumer clientId=consumer-Topics-4, groupId=Topics] Unsubscribed all topics or patterns and assigned partitions
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:1074 - [Consumer clientId=consumer-Topics-3, groupId=Topics] Unsubscribed all topics or patterns and assigned partitions
2024-06-23 19:39:42.840 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  org.apache.kafka.clients.consumer.KafkaConsumer:1074 - [Consumer clientId=consumer-Topics-2, groupId=Topics] Unsubscribed all topics or patterns and assigned partitions
2024-06-23 19:39:42.846 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:659 - Metrics scheduler closed
2024-06-23 19:39:42.846 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:663 - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2024-06-23 19:39:42.846 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:669 - Metrics reporters closed
2024-06-23 19:39:42.849 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  org.apache.kafka.common.utils.AppInfoParser:83 - App info kafka.consumer for consumer-Topics-4 unregistered
2024-06-23 19:39:42.850 [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: Consumer stopped
2024-06-23 19:39:42.850 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:659 - Metrics scheduler closed
2024-06-23 19:39:42.850 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:663 - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2024-06-23 19:39:42.850 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:669 - Metrics reporters closed
2024-06-23 19:39:42.850 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:659 - Metrics scheduler closed
2024-06-23 19:39:42.851 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:663 - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2024-06-23 19:39:42.851 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  org.apache.kafka.common.metrics.Metrics:669 - Metrics reporters closed
2024-06-23 19:39:42.851 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.common.utils.AppInfoParser:83 - App info kafka.consumer for consumer-Topics-3 unregistered
2024-06-23 19:39:42.852 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: Consumer stopped
2024-06-23 19:39:42.852 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  org.apache.kafka.common.utils.AppInfoParser:83 - App info kafka.consumer for consumer-Topics-2 unregistered
2024-06-23 19:39:42.852 [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] INFO  o.s.kafka.listener.KafkaMessageListenerContainer:292 - Topics: Consumer stopped
2024-06-23 19:39:42.853 [SpringApplicationShutdownHook] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:643 - Shutdown ignored - container is already stopped
2024-06-23 19:39:42.853 [SpringApplicationShutdownHook] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:643 - Shutdown ignored - container is already stopped
2024-06-23 19:39:42.853 [SpringApplicationShutdownHook] INFO  o.s.a.r.listener.SimpleMessageListenerContainer:643 - Shutdown ignored - container is already stopped
2024-06-23 19:39:42.865 [SpringApplicationShutdownHook] INFO  org.apache.kafka.clients.producer.KafkaProducer:1204 - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 30000 ms.
2024-06-23 19:39:42.865 [SpringApplicationShutdownHook] INFO  org.apache.kafka.common.metrics.Metrics:659 - Metrics scheduler closed
2024-06-23 19:39:42.865 [SpringApplicationShutdownHook] INFO  org.apache.kafka.common.metrics.Metrics:663 - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2024-06-23 19:39:42.866 [SpringApplicationShutdownHook] INFO  org.apache.kafka.common.metrics.Metrics:669 - Metrics reporters closed
2024-06-23 19:39:42.866 [SpringApplicationShutdownHook] INFO  org.apache.kafka.common.utils.AppInfoParser:83 - App info kafka.producer for producer-1 unregistered
2024-06-23 19:39:43.093 [SpringApplicationShutdownHook] INFO  com.zaxxer.hikari.HikariDataSource:350 - HikariPool-1 - Shutdown initiated...
2024-06-23 19:39:43.101 [SpringApplicationShutdownHook] INFO  com.zaxxer.hikari.HikariDataSource:352 - HikariPool-1 - Shutdown completed.
