search

sitewhere / sitewhere

SiteWhere is an industrial strength open-source application enablement platform for the Internet of Things (IoT). It provides a multi-tenant microservice-based infrastructure that includes device/asset management, data ingestion, big-data storage, and integration through a modern, scalable architecture. SiteWhere provides REST APIs for all system functionality. SiteWhere provides SDKs for many common device platforms including Android, iOS, Arduino, and any Java-capable platform such as Raspberry Pi rapidly accelerating the speed of innovation.
https://sitewhere.io
Other
1.01k stars 383 forks source link

How can l send mqtt json message to SiteWhere instead of REST? #706

Open Javacppc opened 5 years ago

Javacppc commented 5 years ago

l use RESTful API to connect to SiteWhere.For Example,l invoke /sitewhere/api/assignments/xxx/alerts to make alert. but how can l use mqtt to send?

derekadams commented 5 years ago

Each tenant has a list of event sources that may be used to send data into the system for that tenant. By default, tenants are configured with an event source that accepts JSON payloads over MQTT on the topic SiteWhere/${tenant.token}/input/json. So if you want to send JSON data to the default tenant, you would send MQTT payloads to the topic SiteWhere/default/input/json. The payload format for the messages is covered here: https://sitewhere.io/docs/2.0.0/guide/devices/sending-data.html

Hope that helps!

Javacppc commented 5 years ago

Thanks! but l still have a question. l configure rabbitmq with Sitewhere. And l create a topic and send some data(send device location) to rabbitmq,the message was consumed. the data is just like this: { "type": "DeviceLocation", "originator": "device", "deviceToken": "5981-GALAXYTAB3-3488136", "request": { "latitude": "39", "latitude": "-81", "elevation": "1", "updateState": true, "eventDate": "2019-04-11T09:27:03.390Z" } } but it won't work. ls my deviceToken wrong?what is deviceToken? is assignmentToken?

agtzdimi commented 5 years ago

Hello @Javacppc ,

In my first try I have also faced it. There is a typo in the documentation. The "latitude" should be "longitude" in the JSON message. Also to monitor the Error message you should see the logs from event sources microservice. In my case I am producing a logFile like "kubectl logs sitewhere-event-sources-979d59d5b-xfqgx > logFile" and the same goes for other services, too.

sitewhere-iot commented 4 years ago

I send: mosquitto_pub -h 192.168.10.129 -p 1883 -t 'SiteWhere/default/input/json' -m {"type":"DeviceLocation","originator":"device","deviceToken":"71829-IPHONE6S-7215048","request":{"latitude":"39","latitude":"-81","elevation":"1","updateState":true,"eventDate":"2020-06-25 13:58:57"}} -q 1

sitewhere-iot commented 4 years ago

image

sitewhere-iot commented 4 years ago

kubectl -n sitewhere logs sitewhere-event-sources-85dbb59d77-6xrfx sitewhere-event-sources 2020-06-25 12:47:16,465 INFO [com.sit.sou.mic.EventSourcesMicroservice] (main) Starting microservice... 2020-06-25 12:47:16,596 INFO [com.sit.sou.mic.EventSourcesMicroservice] (main) Initializing Kubernetes connectivity... 2020-06-25 12:47:21,141 INFO [com.sit.sou.mic.EventSourcesMicroservice] (main) Kubernetes connectivity initialized. 2020-06-25 12:47:22,206 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) 

    ____        __           __      __  __                             
   /\  _`\   __/\ \__       /\ \  __/\ \/\ \                            
   \ \,\L\_\/\_\ \ ,_\    __\ \ \/\ \ \ \ \ \___      __   _ __    __   
    \/_\__ \\/\ \ \ \/  /'__`\ \ \ \ \ \ \ \  _ `\  /'__`\/\`'__\/'__`\ 
      /\ \L\ \ \ \ \ \_/\  __/\ \ \_/ \_\ \ \ \ \ \/\  __/\ \ \//\  __/ 
      \ `\____\ \_\ \__\ \____\\ `\___x___/\ \_\ \_\ \____\\ \_\\ \____\
       \/_____/\/_/\/__/\/____/ '\/__//__/  \/_/\/_/\/____/ \/_/ \/____/

               The Open Platform for the Internet of Things (TM)
                         Event Sources Microservice

2020-06-25 12:47:22,301 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) EventSourcesMicroservice state transitioned to INITIALIZING. 2020-06-25 12:47:22,301 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Waiting for configuration to be loaded... 2020-06-25 12:47:23,092 WARN [io.fab.kub.cli.int.VersionUsageUtils] (informer-controller-SiteWhereMicroservice) The client is using resource type 'microservices' with unstable version 'v1alpha3' 2020-06-25 12:47:23,131 WARN [io.fab.kub.cli.int.VersionUsageUtils] (informer-controller-SiteWhereScriptVersion) The client is using resource type 'scriptversions' with unstable version 'v1alpha3' 2020-06-25 12:47:23,114 WARN [io.fab.kub.cli.int.VersionUsageUtils] (informer-controller-SiteWhereInstance) The client is using resource type 'instances' with unstable version 'v1alpha3' 2020-06-25 12:47:23,131 WARN [io.fab.kub.cli.int.VersionUsageUtils] (informer-controller-SiteWhereScript) The client is using resource type 'scripts' with unstable version 'v1alpha3' 2020-06-25 12:47:23,131 WARN [io.fab.kub.cli.int.VersionUsageUtils] (informer-controller-SiteWhereTenantEngine) The client is using resource type 'tenantengines' with unstable version 'v1alpha3' 2020-06-25 12:47:29,914 INFO [com.sit.mic.con.InstanceConfigurationMonitor] (Instance Cfg) Detected CREATE resource change in instance sitewhere. 2020-06-25 12:47:30,133 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Instance Cfg) Waiting for microservice configuration to be loaded before starting. 2020-06-25 12:47:31,511 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice asset-management-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice batch-operations-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice command-delivery-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice device-management-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice device-registration-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice device-state-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice event-management-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice event-sources-microservice. 2020-06-25 12:47:31,512 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Microservice Cfg) Handling microservice resource update. configured=false updated=false 2020-06-25 12:47:31,513 INFO [com.sit.mic.con.TenantEngineConfigurationMonitor] (TenantEngine Cfg) Detected CREATE resource change in tenant engine default-event-sources-microservice-1592829021522. 2020-06-25 12:47:31,517 INFO [com.sit.mic.mul.TenantEngineManager] (TenantEngine Cfg) Adding new tenant engine to initialization queue: 'default-event-sources-microservice-1592829021522' 2020-06-25 12:47:35,993 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Initializing Redis connectivity... 2020-06-25 12:47:35,996 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice inbound-processing-microservice. 2020-06-25 12:47:36,011 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice instance-management-microservice. 2020-06-25 12:47:36,011 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice label-generation-microservice. 2020-06-25 12:47:36,011 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice outbound-connectors-microservice. 2020-06-25 12:47:36,011 INFO [com.sit.mic.con.MicroserviceConfigurationMonitor] (Microservice Cfg) Detected CREATE resource change in microservice schedule-management-microservice. 2020-06-25 12:47:36,312 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:47:36,312 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:47:36,312 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:47:38,395 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:47:49,757 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:47:52,761 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:47:52,761 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:47:52,761 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:47:52,772 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:47:58,990 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:02,047 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:02,047 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:02,047 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:02,050 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:08,553 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:11,579 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:11,579 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:11,580 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:11,613 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:17,765 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:20,796 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:20,797 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:20,797 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:20,941 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:27,510 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:30,513 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:30,513 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:30,513 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:30,535 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:37,679 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:40,692 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:40,695 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:40,695 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:40,707 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:47,432 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:50,432 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:50,434 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:50,434 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:50,438 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:56,466 WARN [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Unable to establish Redis connection.: org.redisson.client.RedisTimeoutException: Command execution timeout for sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system/10.106.182.91:26379 at org.redisson.client.RedisConnection.await(RedisConnection.java:147) at org.redisson.client.RedisConnection.sync(RedisConnection.java:179) at org.redisson.client.RedisConnection.sync(RedisConnection.java:165) at org.redisson.connection.SentinelConnectionManager.(SentinelConnectionManager.java:124) at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:197) at org.redisson.Redisson.(Redisson.java:120) at org.redisson.Redisson.create(Redisson.java:160) at com.sitewhere.microservice.Microservice.initializeRedisConnectivity(Microservice.java:247) at com.sitewhere.microservice.Microservice.initialize(Microservice.java:155) at com.sitewhere.microservice.configuration.ConfigurableMicroservice.initialize(ConfigurableMicroservice.java:159) at com.sitewhere.microservice.multitenant.MultitenantMicroservice.initialize(MultitenantMicroservice.java:58) at com.sitewhere.sources.microservice.EventSourcesMicroservice.initialize(EventSourcesMicroservice.java:97) at com.sitewhere.microservice.lifecycle.LifecycleComponent.lifecycleInitialize(LifecycleComponent.java:198) at com.sitewhere.sources.microservice.EventSourcesMicroservice_ClientProxy.lifecycleInitialize(EventSourcesMicroservice_ClientProxy.zig:1416) at com.sitewhere.microservice.MicroserviceApplication.startMicroservice(MicroserviceApplication.java:118) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:155) at com.sitewhere.microservice.MicroserviceApplication$StartMicroservice.call(MicroserviceApplication.java:147) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

2020-06-25 12:48:59,468 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-0.sitewhere-system:26379' and added to list. 2020-06-25 12:48:59,470 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-1.sitewhere-system:26379' and added to list. 2020-06-25 12:48:59,470 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Computed Redis Sentinal node name 'redis://sitewhere-infrastructure-redis-ha-announce-2.sitewhere-system:26379' and added to list. 2020-06-25 12:48:59,473 INFO [org.red.Version] (Service Main) Redisson 3.12.0 2020-06-25 12:48:59,521 INFO [org.red.con.SentinelConnectionManager] (Service Main) master: redis://10.106.182.91:6379 added 2020-06-25 12:48:59,535 INFO [org.red.con.SentinelConnectionManager] (redisson-netty-26-10) sentinel: redis://10.106.182.91:26379 added 2020-06-25 12:48:59,588 WARN [org.red.con.SentinelConnectionManager] (Service Main) ReadMode = SLAVE, but slave nodes are not found! 2020-06-25 12:48:59,653 INFO [org.red.con.poo.SlaveConnectionPool] (redisson-netty-26-32) 24 connections initialized for 10.106.182.91/10.106.182.91:6379 2020-06-25 12:48:59,659 INFO [org.red.con.poo.PubSubConnectionPool] (redisson-netty-26-29) 1 connections initialized for 10.106.182.91/10.106.182.91:6379 2020-06-25 12:48:59,668 INFO [org.red.con.poo.MasterPubSubConnectionPool] (redisson-netty-26-16) 1 connections initialized for 10.106.182.91/10.106.182.91:6379 2020-06-25 12:48:59,674 INFO [org.red.con.poo.MasterConnectionPool] (redisson-netty-26-15) 24 connections initialized for 10.106.182.91/10.106.182.91:6379 2020-06-25 12:48:59,953 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) Redis connectivity initialized. 2020-06-25 12:49:00,076 INFO [com.sit.mic.scr.ScriptManager] (Service Main) ScriptManager state transitioned to INITIALIZING. 2020-06-25 12:49:01,838 INFO [com.sit.mic.scr.ScriptManager] (Service Main) ScriptManager state transitioned to INITIALIZED. 2020-06-25 12:49:01,839 INFO [com.sit.mic.scr.ScriptManager] (Service Main) ScriptManager state transitioned to STARTING. 2020-06-25 12:49:01,839 INFO [com.sit.mic.scr.ScriptManager] (Service Main) ScriptManager state transitioned to STARTED. 2020-06-25 12:49:01,840 INFO [com.sit.mic.scr.ScriptTemplateManager] (Service Main) ScriptTemplateManager state transitioned to INITIALIZING. 2020-06-25 12:49:01,840 INFO [com.sit.mic.scr.ScriptTemplateManager] (Service Main) ScriptTemplateManager state transitioned to INITIALIZED. 2020-06-25 12:49:01,840 INFO [com.sit.mic.scr.ScriptTemplateManager] (Service Main) ScriptTemplateManager state transitioned to STARTING. 2020-06-25 12:49:01,840 INFO [com.sit.mic.scr.ScriptTemplateManager] (Service Main) ScriptTemplateManager state transitioned to STARTED. 2020-06-25 12:49:01,840 INFO [com.sit.mic.met.MetricsServer] (Service Main) MetricsServer state transitioned to INITIALIZING. 2020-06-25 12:49:01,840 INFO [com.sit.mic.met.MetricsServer] (Service Main) MetricsServer state transitioned to INITIALIZED. 2020-06-25 12:49:01,840 INFO [com.sit.mic.met.MetricsServer] (Service Main) MetricsServer state transitioned to STARTING. 2020-06-25 12:49:02,470 INFO [com.sit.mic.met.MetricsServer] (Service Main) Microservice metrics available via HTTP on port 9090. 2020-06-25 12:49:02,470 INFO [com.sit.mic.met.MetricsServer] (Service Main) MetricsServer state transitioned to STARTED. 2020-06-25 12:49:02,471 INFO [com.sit.mic.ten.per.KubernetesTenantManagement] (Service Main) KubernetesTenantManagement state transitioned to INITIALIZING. 2020-06-25 12:49:02,471 INFO [com.sit.mic.ten.per.KubernetesTenantManagement] (Service Main) KubernetesTenantManagement state transitioned to INITIALIZED. 2020-06-25 12:49:02,471 INFO [com.sit.mic.ten.per.KubernetesTenantManagement] (Service Main) KubernetesTenantManagement state transitioned to STARTING. 2020-06-25 12:49:02,471 INFO [com.sit.mic.ten.per.KubernetesTenantManagement] (Service Main) KubernetesTenantManagement state transitioned to STARTED. 2020-06-25 12:49:04,121 INFO [com.sit.mic.scr.KubernetesScriptManagement] (Service Main) KubernetesScriptManagement state transitioned to INITIALIZING. 2020-06-25 12:49:04,121 INFO [com.sit.mic.scr.KubernetesScriptManagement] (Service Main) KubernetesScriptManagement state transitioned to INITIALIZED. 2020-06-25 12:49:04,121 INFO [com.sit.mic.scr.KubernetesScriptManagement] (Service Main) KubernetesScriptManagement state transitioned to STARTING. 2020-06-25 12:49:04,121 INFO [com.sit.mic.scr.KubernetesScriptManagement] (Service Main) KubernetesScriptManagement state transitioned to STARTED. 2020-06-25 12:49:04,121 INFO [com.sit.mic.mul.TenantEngineManager] (Service Main) TenantEngineManager state transitioned to INITIALIZING. 2020-06-25 12:49:04,122 INFO [com.sit.mic.mul.TenantEngineManager] (Service Main) TenantEngineManager state transitioned to INITIALIZED. 2020-06-25 12:49:04,633 INFO [com.sit.grp.cli.dev.CachedDeviceManagementApiChannel] (Service Main) CachedDeviceManagementApiChannel state transitioned to INITIALIZING. 2020-06-25 12:49:04,633 INFO [com.sit.grp.cli.dev.DeviceManagementApiChannel] (Service Main) DeviceManagementApiChannel state transitioned to INITIALIZING. 2020-06-25 12:49:04,850 INFO [com.sit.grp.cli.dev.DeviceManagementApiChannel] (Service Main) Initializing gRPC channel for DeviceManagement to 'sitewhere-device-management-svc:9000' 2020-06-25 12:49:04,850 INFO [com.sit.grp.cli.dev.DeviceManagementGrpcChannel] (Service Main) DeviceManagementGrpcChannel state transitioned to INITIALIZING. 2020-06-25 12:49:04,850 INFO [com.sit.grp.cli.dev.DeviceManagementGrpcChannel] (Service Main) DeviceManagementGrpcChannel state transitioned to INITIALIZED. 2020-06-25 12:49:04,851 INFO [com.sit.grp.cli.dev.DeviceManagementApiChannel] (Service Main) DeviceManagementApiChannel state transitioned to INITIALIZED. 2020-06-25 12:49:04,891 INFO [com.sit.grp.cli.dev.CachedDeviceManagementApiChannel] (Service Main) CachedDeviceManagementApiChannel state transitioned to INITIALIZED. 2020-06-25 12:49:04,891 INFO [com.sit.grp.cli.eve.DeviceEventManagementApiChannel] (Service Main) DeviceEventManagementApiChannel state transitioned to INITIALIZING. 2020-06-25 12:49:04,892 INFO [com.sit.grp.cli.eve.DeviceEventManagementApiChannel] (Service Main) Initializing gRPC channel for EventManagement to 'sitewhere-event-management-svc:9000' 2020-06-25 12:49:04,892 INFO [com.sit.grp.cli.eve.DeviceEventManagementGrpcChannel] (Service Main) DeviceEventManagementGrpcChannel state transitioned to INITIALIZING. 2020-06-25 12:49:04,892 INFO [com.sit.grp.cli.eve.DeviceEventManagementGrpcChannel] (Service Main) DeviceEventManagementGrpcChannel state transitioned to INITIALIZED. 2020-06-25 12:49:04,892 INFO [com.sit.grp.cli.eve.DeviceEventManagementApiChannel] (Service Main) DeviceEventManagementApiChannel state transitioned to INITIALIZED. 2020-06-25 12:49:04,892 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) EventSourcesMicroservice state transitioned to INITIALIZED. 2020-06-25 12:49:04,892 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) EventSourcesMicroservice state transitioned to STARTING. 2020-06-25 12:49:04,892 INFO [com.sit.mic.mul.TenantEngineManager] (Service Main) TenantEngineManager state transitioned to STARTING. 2020-06-25 12:49:05,123 INFO [com.sit.mic.mul.TenantEngineManager] (Service Main) Adding existing tenant engine to initialization queue: 'default-event-sources-microservice-1592829021522' 2020-06-25 12:49:05,124 INFO [com.sit.mic.mul.TenantEngineManager] (Service Main) TenantEngineManager state transitioned to STARTED. 2020-06-25 12:49:05,124 INFO [com.sit.grp.cli.dev.CachedDeviceManagementApiChannel] (Service Main) CachedDeviceManagementApiChannel state transitioned to STARTING. 2020-06-25 12:49:05,124 INFO [com.sit.grp.cli.dev.DeviceManagementApiChannel] (Service Main) DeviceManagementApiChannel state transitioned to STARTING. 2020-06-25 12:49:05,124 INFO [com.sit.grp.cli.dev.DeviceManagementApiChannel] (Service Main) Starting gRPC channel to 'sitewhere-device-management-svc:9000' 2020-06-25 12:49:05,167 INFO [com.sit.grp.cli.dev.DeviceManagementGrpcChannel] (Service Main) DeviceManagementGrpcChannel state transitioned to STARTING. 2020-06-25 12:49:07,291 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 2) Starting to process tenant shutdown queue. 2020-06-25 12:49:07,310 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 1) Starting to process tenant startup queue. 2020-06-25 12:49:07,425 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 1) Creating tenant engine for 'default-event-sources-microservice-1592829021522'... 2020-06-25 12:49:07,535 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 1) Intializing tenant engine for 'default-event-sources-microservice-1592829021522'. 2020-06-25 12:49:07,535 INFO [com.sit.sou.mic.EventSourcesTenantEngine] (Tenant Ops 1) EventSourcesTenantEngine state transitioned to INITIALIZING. 2020-06-25 12:49:08,991 WARN [io.fab.kub.cli.int.VersionUsageUtils] (Tenant Ops 1) The client is using resource type 'tenants' with unstable version 'v1alpha3' 2020-06-25 12:49:12,398 INFO [com.sit.grp.cli.dev.DeviceManagementGrpcChannel] (Service Main) Channel using service configuration:

{ "methodConfig" : [ { "retryPolicy" : { "backoffMultiplier" : 1.5, "maxAttempts" : 6.0, "initialBackoff" : "10s", "retryableStatusCodes" : [ "UNAVAILABLE" ], "maxBackoff" : "600s" }, "name" : [ { "service" : "com.sitewhere.grpc.service.DeviceManagement" } ] } ] } 2020-06-25 12:49:16,282 INFO [com.sit.mic.scr.ScriptManager] (Tenant Ops 1) ScriptManager state transitioned to INITIALIZING. 2020-06-25 12:49:17,146 INFO [com.sit.mic.scr.ScriptManager] (Tenant Ops 1) ScriptManager state transitioned to INITIALIZED. 2020-06-25 12:49:17,146 INFO [com.sit.mic.mul.TenantEngineBootstrapper] (Tenant Ops 1) TenantEngineBootstrapper state transitioned to INITIALIZING. 2020-06-25 12:49:17,147 INFO [com.sit.mic.mul.TenantEngineBootstrapper] (Tenant Ops 1) TenantEngineBootstrapper state transitioned to INITIALIZED. 2020-06-25 12:49:17,147 INFO [com.sit.sou.man.EventSourcesManager] (Tenant Ops 1) EventSourcesManager state transitioned to INITIALIZING. 2020-06-25 12:49:17,148 INFO [com.sit.sou.man.EventSourcesManager] (Tenant Ops 1) About to initialize event sources manager with configuration: [ { "id" : "json", "type" : "mqtt", "decoder" : { "type" : "json", "configuration" : { } }, "configuration" : { "hostname" : "sitewhere-infrastructure-mosquitto.sitewhere-system", "numThreads" : 3, "port" : 1883, "topic" : "SiteWhere/${tenant.token}/input/json" } }, { "id" : "protobuf", "type" : "mqtt", "decoder" : { "type" : "protobuf", "configuration" : { } }, "configuration" : { "hostname" : "sitewhere-infrastructure-mosquitto.sitewhere-system", "numThreads" : 3, "port" : 1883, "topic" : "SiteWhere/${tenant.token}/input/protobuf" } } ]

2020-06-25 12:49:17,735 INFO [com.sit.sou.man.EventSourcesParser] (Tenant Ops 1) Creating MQTT event source with configuration: { "id" : "json", "decoder" : { "type" : "json", "configuration" : { } }, "protocol" : "tcp", "hostname" : "sitewhere-infrastructure-mosquitto.sitewhere-system", "port" : 1883, "trustStorePath" : null, "trustStorePassword" : null, "keyStorePath" : null, "keyStorePassword" : null, "username" : null, "password" : null, "clientId" : null, "cleanSession" : true, "topic" : "SiteWhere/default/input/json", "numThreads" : 3, "qos" : 0 }

2020-06-25 12:49:17,788 INFO [com.sit.grp.cli.dev.DeviceManagementGrpcChannel] (Service Main) Creating gRPC client channel connected to sitewhere-device-management-svc:9000 ... 2020-06-25 12:49:17,788 INFO [com.sit.grp.cli.dev.DeviceManagementGrpcChannel] (Service Main) DeviceManagementGrpcChannel state transitioned to STARTED. 2020-06-25 12:49:17,788 INFO [com.sit.grp.cli.dev.DeviceManagementApiChannel] (Service Main) DeviceManagementApiChannel state transitioned to STARTED. 2020-06-25 12:49:17,788 INFO [com.sit.grp.cli.dev.CachedDeviceManagementApiChannel] (Service Main) CachedDeviceManagementApiChannel state transitioned to STARTED. 2020-06-25 12:49:17,788 INFO [com.sit.grp.cli.eve.DeviceEventManagementApiChannel] (Service Main) DeviceEventManagementApiChannel state transitioned to STARTING. 2020-06-25 12:49:17,789 INFO [com.sit.grp.cli.eve.DeviceEventManagementApiChannel] (Service Main) Starting gRPC channel to 'sitewhere-event-management-svc:9000' 2020-06-25 12:49:17,789 INFO [com.sit.grp.cli.eve.DeviceEventManagementGrpcChannel] (Service Main) DeviceEventManagementGrpcChannel state transitioned to STARTING. 2020-06-25 12:49:17,789 INFO [com.sit.grp.cli.eve.DeviceEventManagementGrpcChannel] (Service Main) Channel using service configuration:

{ "methodConfig" : [ { "retryPolicy" : { "backoffMultiplier" : 1.5, "maxAttempts" : 6.0, "initialBackoff" : "10s", "retryableStatusCodes" : [ "UNAVAILABLE" ], "maxBackoff" : "600s" }, "name" : [ { "service" : "com.sitewhere.grpc.service.DeviceEventManagement" } ] } ] } 2020-06-25 12:49:17,810 INFO [com.sit.sou.man.EventSourcesParser] (Tenant Ops 1) Creating MQTT event source with configuration: { "id" : "protobuf", "decoder" : { "type" : "protobuf", "configuration" : { } }, "protocol" : "tcp", "hostname" : "sitewhere-infrastructure-mosquitto.sitewhere-system", "port" : 1883, "trustStorePath" : null, "trustStorePassword" : null, "keyStorePath" : null, "keyStorePassword" : null, "username" : null, "password" : null, "clientId" : null, "cleanSession" : true, "topic" : "SiteWhere/default/input/protobuf", "numThreads" : 3, "qos" : 0 }

2020-06-25 12:49:17,836 INFO [com.sit.grp.cli.eve.DeviceEventManagementGrpcChannel] (Service Main) Creating gRPC client channel connected to sitewhere-event-management-svc:9000 ... 2020-06-25 12:49:17,836 INFO [com.sit.grp.cli.eve.DeviceEventManagementGrpcChannel] (Service Main) DeviceEventManagementGrpcChannel state transitioned to STARTED. 2020-06-25 12:49:17,836 INFO [com.sit.grp.cli.eve.DeviceEventManagementApiChannel] (Service Main) DeviceEventManagementApiChannel state transitioned to STARTED. 2020-06-25 12:49:17,836 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main) EventSourcesMicroservice state transitioned to STARTED. 2020-06-25 12:49:17,837 INFO [com.sit.sou.mic.EventSourcesMicroservice] (Service Main)

2020-06-25 12:49:17,838 INFO [com.sit.sou.mic.EventSourcesMicroservice] (main) Microservice startup completed. 2020-06-25 12:49:17,842 INFO [io.quarkus] (main) service-event-sources 3.0.0.beta1 (running on Quarkus 1.2.1.Final) started in 153.122s. 2020-06-25 12:49:17,843 INFO [io.quarkus] (main) Profile prod activated. 2020-06-25 12:49:17,843 INFO [io.quarkus] (main) Installed features: [cdi, kubernetes-client] 2020-06-25 12:49:17,881 INFO [com.sit.sou.kaf.DecodedEventsProducer] (Tenant Ops 1) DecodedEventsProducer state transitioned to INITIALIZING. 2020-06-25 12:49:17,881 INFO [com.sit.sou.kaf.DecodedEventsProducer] (Tenant Ops 1) DecodedEventsProducer state transitioned to INITIALIZED. 2020-06-25 12:49:17,882 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (Tenant Ops 1) FailedDecodeEventsProducer state transitioned to INITIALIZING. 2020-06-25 12:49:17,882 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (Tenant Ops 1) FailedDecodeEventsProducer state transitioned to INITIALIZED. 2020-06-25 12:49:17,882 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (Tenant Ops 1) DeviceRegistrationEventsProducer state transitioned to INITIALIZING. 2020-06-25 12:49:17,882 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (Tenant Ops 1) DeviceRegistrationEventsProducer state transitioned to INITIALIZED. 2020-06-25 12:49:17,882 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to INITIALIZING. 2020-06-25 12:49:17,882 INFO [com.sit.sou.dec.jso.JsonDeviceRequestDecoder] (Tenant Ops 1) JsonDeviceRequestDecoder state transitioned to INITIALIZING. 2020-06-25 12:49:17,882 INFO [com.sit.sou.dec.jso.JsonDeviceRequestDecoder] (Tenant Ops 1) JsonDeviceRequestDecoder state transitioned to INITIALIZED. 2020-06-25 12:49:17,882 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to INITIALIZING. 2020-06-25 12:49:17,882 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to INITIALIZED. 2020-06-25 12:49:17,882 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to INITIALIZED. 2020-06-25 12:49:17,883 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to INITIALIZING. 2020-06-25 12:49:17,883 INFO [com.sit.sou.dec.pro.ProtobufDeviceEventDecoder] (Tenant Ops 1) ProtobufDeviceEventDecoder state transitioned to INITIALIZING. 2020-06-25 12:49:17,883 INFO [com.sit.sou.dec.pro.ProtobufDeviceEventDecoder] (Tenant Ops 1) ProtobufDeviceEventDecoder state transitioned to INITIALIZED. 2020-06-25 12:49:17,883 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to INITIALIZING. 2020-06-25 12:49:17,883 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to INITIALIZED. 2020-06-25 12:49:17,883 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to INITIALIZED. 2020-06-25 12:49:17,883 INFO [com.sit.sou.man.EventSourcesManager] (Tenant Ops 1) EventSourcesManager state transitioned to INITIALIZED. 2020-06-25 12:49:17,883 INFO [com.sit.sou.mic.EventSourcesTenantEngine] (Tenant Ops 1) EventSourcesTenantEngine state transitioned to INITIALIZED. 2020-06-25 12:49:17,883 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 1) Tenant engine for 'default-event-sources-microservice-1592829021522' initialized in 10348ms. 2020-06-25 12:49:17,883 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 1) Starting tenant engine for 'default-event-sources-microservice-1592829021522'. 2020-06-25 12:49:17,883 INFO [com.sit.sou.mic.EventSourcesTenantEngine] (Tenant Ops 1) EventSourcesTenantEngine state transitioned to STARTING. 2020-06-25 12:49:17,883 INFO [com.sit.mic.scr.ScriptManager] (Tenant Ops 1) ScriptManager state transitioned to STARTING. 2020-06-25 12:49:17,884 INFO [com.sit.mic.scr.ScriptManager] (Tenant Ops 1) ScriptManager state transitioned to STARTED. 2020-06-25 12:49:17,884 INFO [com.sit.sou.man.EventSourcesManager] (Tenant Ops 1) EventSourcesManager state transitioned to STARTING. 2020-06-25 12:49:17,884 INFO [com.sit.sou.kaf.DecodedEventsProducer] (Tenant Ops 1) DecodedEventsProducer state transitioned to STARTING. 2020-06-25 12:49:17,884 INFO [com.sit.sou.kaf.DecodedEventsProducer] (Tenant Ops 1) Producer connecting to Kafka: sitewhere-kafka-kafka-bootstrap.sitewhere-system:9092 2020-06-25 12:49:17,892 INFO [com.sit.sou.kaf.DecodedEventsProducer] (Tenant Ops 1) Will be producing messages for: sitewhere.sitewhere.tenant.default.event-source-decoded-events 2020-06-25 12:49:17,894 INFO [com.sit.sou.kaf.DecodedEventsProducer] (Tenant Ops 1) DecodedEventsProducer state transitioned to STARTED. 2020-06-25 12:49:17,895 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (Tenant Ops 1) FailedDecodeEventsProducer state transitioned to STARTING. 2020-06-25 12:49:17,895 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (Tenant Ops 1) Producer connecting to Kafka: sitewhere-kafka-kafka-bootstrap.sitewhere-system:9092 2020-06-25 12:49:17,895 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (Tenant Ops 1) Will be producing messages for: sitewhere.sitewhere.tenant.default.event-source-failed-decode-events 2020-06-25 12:49:17,895 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (Tenant Ops 1) FailedDecodeEventsProducer state transitioned to STARTED. 2020-06-25 12:49:17,898 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (Tenant Ops 1) DeviceRegistrationEventsProducer state transitioned to STARTING. 2020-06-25 12:49:17,898 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (Tenant Ops 1) Producer connecting to Kafka: sitewhere-kafka-kafka-bootstrap.sitewhere-system:9092 2020-06-25 12:49:17,898 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (Tenant Ops 1) Will be producing messages for: sitewhere.sitewhere.tenant.default.inbound-device-registration-events 2020-06-25 12:49:17,895 INFO [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Attempting to connect to Kafka... 2020-06-25 12:49:17,900 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (Tenant Ops 1) DeviceRegistrationEventsProducer state transitioned to STARTED. 2020-06-25 12:49:17,901 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to STARTING. 2020-06-25 12:49:17,901 INFO [com.sit.sou.dec.jso.JsonDeviceRequestDecoder] (Tenant Ops 1) JsonDeviceRequestDecoder state transitioned to STARTING. 2020-06-25 12:49:17,901 INFO [com.sit.sou.dec.jso.JsonDeviceRequestDecoder] (Tenant Ops 1) JsonDeviceRequestDecoder state transitioned to STARTED. 2020-06-25 12:49:17,901 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to STARTING. 2020-06-25 12:49:17,902 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Attempting to connect to Kafka... 2020-06-25 12:49:17,902 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Attempting to connect to Kafka... 2020-06-25 12:49:18,477 INFO [com.sit.com.mqt.MqttConfigurer] (Tenant Ops 1) MQTT clean session flag being set to 'true'. 2020-06-25 12:49:18,563 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Receiver connecting to MQTT broker at 'tcp://sitewhere-infrastructure-mosquitto.sitewhere-system:1883'... 2020-06-25 12:49:22,447 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 12:49:22,448 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:49:22,448 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593089362441 2020-06-25 12:49:22,450 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 12:49:22,451 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:49:22,452 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593089362441 2020-06-25 12:49:22,452 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 12:49:22,453 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:49:22,453 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593089362441 2020-06-25 12:49:22,621 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Receiver connected to MQTT broker. 2020-06-25 12:49:22,621 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Suscribing using QoS: 0 2020-06-25 12:49:22,640 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Subscribed to events on MQTT topic SiteWhere/default/input/json using 3 processing threads. 2020-06-25 12:49:22,644 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to STARTED. 2020-06-25 12:49:22,644 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (SiteWhere MQTT(json - SiteWhere/default/input/json) Receiver 1) Started MQTT subscription processing thread. 2020-06-25 12:49:22,644 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to STARTED. 2020-06-25 12:49:22,667 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to STARTING. 2020-06-25 12:49:22,667 INFO [com.sit.sou.dec.pro.ProtobufDeviceEventDecoder] (Tenant Ops 1) ProtobufDeviceEventDecoder state transitioned to STARTING. 2020-06-25 12:49:22,667 INFO [com.sit.sou.dec.pro.ProtobufDeviceEventDecoder] (Tenant Ops 1) ProtobufDeviceEventDecoder state transitioned to STARTED. 2020-06-25 12:49:22,667 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to STARTING. 2020-06-25 12:49:22,667 INFO [com.sit.com.mqt.MqttConfigurer] (Tenant Ops 1) MQTT clean session flag being set to 'true'. 2020-06-25 12:49:22,667 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Receiver connecting to MQTT broker at 'tcp://sitewhere-infrastructure-mosquitto.sitewhere-system:1883'... 2020-06-25 12:49:22,676 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Receiver connected to MQTT broker. 2020-06-25 12:49:22,677 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Suscribing using QoS: 0 2020-06-25 12:49:22,755 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) Subscribed to events on MQTT topic SiteWhere/default/input/protobuf using 3 processing threads. 2020-06-25 12:49:22,756 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (Tenant Ops 1) MqttInboundEventReceiver state transitioned to STARTED. 2020-06-25 12:49:22,756 INFO [com.sit.sou.mqt.MqttInboundEventReceiver] (SiteWhere MQTT(protobuf - SiteWhere/default/input/protobuf) Receiver 1) Started MQTT subscription processing thread. 2020-06-25 12:49:22,756 INFO [com.sit.sou.BinaryInboundEventSource] (Tenant Ops 1) BinaryInboundEventSource state transitioned to STARTED. 2020-06-25 12:49:22,757 INFO [com.sit.sou.man.EventSourcesManager] (Tenant Ops 1) EventSourcesManager state transitioned to STARTED. 2020-06-25 12:49:22,757 INFO [com.sit.mic.mul.TenantEngineBootstrapper] (Tenant Ops 1) TenantEngineBootstrapper state transitioned to STARTING. 2020-06-25 12:49:22,758 INFO [com.sit.sou.mic.EventSourcesTenantEngine] (Tenant Ops 1) EventSourcesTenantEngine state transitioned to STARTED. 2020-06-25 12:49:22,758 INFO [com.sit.mic.mul.TenantEngineManager] (Tenant Ops 1) Tenant engine for 'default-event-sources-microservice-1592829021522' started in 4875ms. 2020-06-25 12:49:22,768 INFO [com.sit.mic.mul.TenantEngineBootstrapper] (pool-27-thread-1) Tenant engine already bootstrapped. Skipping data bootstrap processing. 2020-06-25 12:51:22,459 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:51:22,459 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:51:22,459 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:51:27,466 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 12:51:27,466 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:51:27,467 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593089487466 2020-06-25 12:51:27,467 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 12:51:27,467 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:51:27,467 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593089487467 2020-06-25 12:51:27,469 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 12:51:27,469 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:51:27,469 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593089487468 2020-06-25 12:53:27,472 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:53:27,472 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:53:27,475 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:53:32,478 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 12:53:32,478 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:53:32,478 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593089612478 2020-06-25 12:53:32,479 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 12:53:32,481 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:53:32,481 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593089612479 2020-06-25 12:53:32,485 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 12:53:32,485 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:53:32,485 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593089612479 2020-06-25 12:55:32,484 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:55:32,487 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:55:32,487 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:55:37,487 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 12:55:37,487 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:55:37,487 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593089737487 2020-06-25 12:55:37,492 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 12:55:37,492 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:55:37,492 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593089737492 2020-06-25 12:55:37,492 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 12:55:37,492 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:55:37,492 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593089737492 2020-06-25 12:57:37,490 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:57:37,494 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:57:37,498 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:57:42,494 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 12:57:42,494 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:57:42,494 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593089862494 2020-06-25 12:57:42,498 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 12:57:42,498 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:57:42,498 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593089862498 2020-06-25 12:57:42,502 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 12:57:42,503 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:57:42,503 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593089862502 2020-06-25 12:59:42,497 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:59:42,502 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:59:42,505 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 12:59:47,500 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 12:59:47,500 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:59:47,500 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593089987500 2020-06-25 12:59:47,505 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 12:59:47,505 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:59:47,505 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593089987505 2020-06-25 12:59:47,513 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 12:59:47,513 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 12:59:47,513 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593089987513 2020-06-25 13:01:47,505 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:01:47,507 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:01:47,515 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:01:52,510 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:01:52,510 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:01:52,510 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090112510 2020-06-25 13:01:52,510 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:01:52,510 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:01:52,510 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090112510 2020-06-25 13:01:52,523 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:01:52,523 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:01:52,523 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090112523 2020-06-25 13:03:52,513 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:03:52,514 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:03:52,527 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:03:57,519 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:03:57,519 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:03:57,519 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090237519 2020-06-25 13:03:57,519 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:03:57,519 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:03:57,519 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090237519 2020-06-25 13:03:57,529 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:03:57,529 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:03:57,529 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090237528 2020-06-25 13:05:57,524 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:05:57,524 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:05:57,532 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:06:02,528 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:06:02,528 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:06:02,528 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090362528 2020-06-25 13:06:02,529 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:06:02,529 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:06:02,529 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090362528 2020-06-25 13:06:02,535 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:06:02,535 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:06:02,535 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090362535 2020-06-25 13:08:02,533 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:08:02,533 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:08:02,538 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:08:07,536 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:08:07,536 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:08:07,536 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090487536 2020-06-25 13:08:07,536 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:08:07,536 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:08:07,537 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090487536 2020-06-25 13:08:07,539 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:08:07,539 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:08:07,539 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090487539 2020-06-25 13:10:07,540 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:10:07,540 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:10:07,544 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:10:12,543 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:10:12,543 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:10:12,543 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090612543 2020-06-25 13:10:12,544 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:10:12,544 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:10:12,544 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090612543 2020-06-25 13:10:12,553 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:10:12,553 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:10:12,553 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090612553 2020-06-25 13:12:12,547 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:12:12,554 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:12:12,560 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:12:17,555 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:12:17,555 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:12:17,555 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090737555 2020-06-25 13:12:17,561 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:12:17,561 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:12:17,561 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090737561 2020-06-25 13:12:17,573 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:12:17,573 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:12:17,573 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090737573 2020-06-25 13:14:17,560 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:14:17,563 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:14:17,574 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:14:22,562 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:14:22,562 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:14:22,562 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090862562 2020-06-25 13:14:22,566 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:14:22,566 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:14:22,566 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090862566 2020-06-25 13:14:22,651 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:14:22,652 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:14:22,652 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090862651 2020-06-25 13:16:22,566 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:16:22,569 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:16:22,655 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:16:27,568 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:16:27,568 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:16:27,568 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593090987568 2020-06-25 13:16:27,572 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:16:27,572 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:16:27,572 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593090987572 2020-06-25 13:16:27,657 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:16:27,657 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:16:27,657 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593090987657 2020-06-25 13:18:27,591 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:18:27,591 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:18:27,660 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:18:32,594 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:18:32,594 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:18:32,594 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091112594 2020-06-25 13:18:32,594 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:18:32,594 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:18:32,596 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091112594 2020-06-25 13:18:32,661 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:18:32,661 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:18:32,661 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091112661 2020-06-25 13:20:32,600 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:20:32,600 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:20:32,663 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:20:37,604 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:20:37,604 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:20:37,604 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091237604 2020-06-25 13:20:37,605 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:20:37,606 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:20:37,606 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091237604 2020-06-25 13:20:37,664 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:20:37,664 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:20:37,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091237664 2020-06-25 13:22:37,607 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:22:37,614 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:22:37,669 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:22:42,616 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:22:42,616 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:22:42,617 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091362616 2020-06-25 13:22:42,617 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:22:42,633 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:22:42,633 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091362617 2020-06-25 13:22:42,671 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:22:42,671 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:22:42,671 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091362671 2020-06-25 13:24:42,620 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:24:42,636 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:24:42,676 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:24:47,635 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:24:47,635 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:24:47,635 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091487635 2020-06-25 13:24:47,640 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:24:47,641 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:24:47,641 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091487640 2020-06-25 13:24:47,678 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:24:47,678 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:24:47,678 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091487678 2020-06-25 13:26:47,640 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:26:47,643 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:26:47,679 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:26:52,643 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:26:52,643 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:26:52,643 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091612643 2020-06-25 13:26:52,644 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:26:52,644 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:26:52,644 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091612644 2020-06-25 13:26:52,680 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:26:52,680 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:26:52,680 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091612680 2020-06-25 13:28:52,647 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:28:52,647 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:28:52,684 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:28:57,649 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:28:57,650 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:28:57,650 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091737649 2020-06-25 13:28:57,650 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:28:57,650 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:28:57,650 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091737649 2020-06-25 13:28:57,685 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:28:57,686 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:28:57,686 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091737685 2020-06-25 13:30:57,653 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:30:57,653 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:30:57,689 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:31:02,656 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:31:02,656 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:31:02,656 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091862656 2020-06-25 13:31:02,656 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:31:02,656 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:31:02,656 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091862656 2020-06-25 13:31:02,691 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:31:02,691 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:31:02,692 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091862691 2020-06-25 13:33:02,662 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:33:02,662 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:33:02,693 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:33:07,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:33:07,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:33:07,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593091987665 2020-06-25 13:33:07,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:33:07,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:33:07,665 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593091987665 2020-06-25 13:33:07,694 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:33:07,695 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:33:07,695 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593091987694 2020-06-25 13:35:07,668 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:35:07,672 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:35:07,700 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:35:12,670 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:35:12,671 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:35:12,671 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092112670 2020-06-25 13:35:12,676 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:35:12,676 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:35:12,676 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092112676 2020-06-25 13:35:12,702 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:35:12,702 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:35:12,702 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092112702 2020-06-25 13:37:12,674 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:37:12,680 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:37:12,705 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:37:17,676 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:37:17,676 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:37:17,676 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092237676 2020-06-25 13:37:17,681 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:37:17,681 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:37:17,681 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092237681 2020-06-25 13:37:17,706 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:37:17,706 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:37:17,707 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092237706 2020-06-25 13:39:17,689 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:39:17,689 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:39:17,708 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:39:22,693 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:39:22,693 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:39:22,693 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092362693 2020-06-25 13:39:22,693 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:39:22,693 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:39:22,693 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092362693 2020-06-25 13:39:22,709 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:39:22,709 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:39:22,709 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092362709 2020-06-25 13:41:22,698 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:41:22,698 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:41:22,713 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:41:27,700 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:41:27,701 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:41:27,701 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092487700 2020-06-25 13:41:27,701 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:41:27,701 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:41:27,701 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092487700 2020-06-25 13:41:27,728 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:41:27,728 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:41:27,728 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092487728 2020-06-25 13:43:27,705 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:43:27,705 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:43:27,731 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:43:32,708 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:43:32,708 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:43:32,708 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092612708 2020-06-25 13:43:32,709 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:43:32,710 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:43:32,710 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092612709 2020-06-25 13:43:32,732 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:43:32,732 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:43:32,732 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092612732 2020-06-25 13:43:52,084 INFO [com.sit.sou.kaf.DecodedEventsProducer] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 1) Producer waiting on Kafka to become available... 2020-06-25 13:45:19,353 INFO [com.sit.sou.kaf.DecodedEventsProducer] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 2) Producer waiting on Kafka to become available... 2020-06-25 13:45:32,715 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:45:32,715 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:45:32,735 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:45:37,717 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:45:37,717 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:45:37,717 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092737717 2020-06-25 13:45:37,717 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:45:37,717 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:45:37,717 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092737717 2020-06-25 13:45:37,737 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:45:37,737 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:45:37,737 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092737737 2020-06-25 13:47:37,727 WARN [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:47:37,727 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:47:37,743 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:47:42,730 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:47:42,730 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:47:42,730 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092862730 2020-06-25 13:47:42,730 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka version: 2.3.1 2020-06-25 13:47:42,730 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:47:42,730 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-30-thread-1) Kafka startTimeMs: 1593092862730 2020-06-25 13:47:42,744 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:47:42,744 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:47:42,744 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092862744 2020-06-25 13:47:55,316 INFO [com.sit.sou.kaf.DeviceRegistrationEventsProducer] (pool-30-thread-1) Kafka detected as available. 2020-06-25 13:49:11,916 INFO [com.sit.sou.kaf.DecodedEventsProducer] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 3) Producer waiting on Kafka to become available... 2020-06-25 13:49:42,733 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:49:42,762 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:49:47,735 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:49:47,735 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:49:47,735 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593092987735 2020-06-25 13:49:47,763 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:49:47,763 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:49:47,763 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593092987763 2020-06-25 13:51:47,740 WARN [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:51:47,764 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:51:52,742 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka version: 2.3.1 2020-06-25 13:51:52,743 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:51:52,743 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-29-thread-1) Kafka startTimeMs: 1593093112742 2020-06-25 13:51:52,765 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:51:52,765 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:51:52,765 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593093112765 2020-06-25 13:53:01,124 INFO [com.sit.sou.kaf.FailedDecodeEventsProducer] (pool-29-thread-1) Kafka detected as available. 2020-06-25 13:53:52,769 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:53:57,771 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:53:57,771 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:53:57,771 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593093237771 2020-06-25 13:55:57,775 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:56:02,778 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:56:02,778 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:56:02,778 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593093362778 2020-06-25 13:58:02,784 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 13:58:07,786 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 13:58:07,786 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 13:58:07,786 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593093487786 2020-06-25 14:00:07,790 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 14:00:12,792 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 14:00:12,792 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 14:00:12,792 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593093612792 2020-06-25 14:02:12,803 WARN [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Execution exception connecting to Kafka. Will continue attempting to connect. (org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.): org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

2020-06-25 14:02:17,806 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka version: 2.3.1 2020-06-25 14:02:17,806 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka commitId: 18a913733fb71c01 2020-06-25 14:02:17,806 INFO [org.apa.kaf.com.uti.AppInfoParser] (pool-28-thread-1) Kafka startTimeMs: 1593093737806 2020-06-25 14:03:14,058 INFO [com.sit.sou.kaf.DecodedEventsProducer] (pool-28-thread-1) Kafka detected as available. 2020-06-25 14:03:14,129 INFO [org.apa.kaf.cli.pro.ProducerConfig] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 3) ProducerConfig values: acks = 0 batch.size = 16384 bootstrap.servers = [sitewhere-kafka-kafka-bootstrap.sitewhere-system:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] 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 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 send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX 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.ByteArraySerializer

2020-06-25 14:03:14,132 INFO [org.apa.kaf.cli.pro.ProducerConfig] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 2) ProducerConfig values: acks = 0 batch.size = 16384 bootstrap.servers = [sitewhere-kafka-kafka-bootstrap.sitewhere-system:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] 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 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 send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX 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.ByteArraySerializer

2020-06-25 14:03:14,132 INFO [org.apa.kaf.cli.pro.ProducerConfig] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 1) ProducerConfig values: acks = 0 batch.size = 16384 bootstrap.servers = [sitewhere-kafka-kafka-bootstrap.sitewhere-system:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] 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 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 send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX 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.ByteArraySerializer

2020-06-25 14:03:14,199 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 1) Kafka version: 2.3.1 2020-06-25 14:03:14,211 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 1) Kafka commitId: 18a913733fb71c01 2020-06-25 14:03:14,212 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 1) Kafka startTimeMs: 1593093794199 2020-06-25 14:03:14,216 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 2) Kafka version: 2.3.1 2020-06-25 14:03:14,216 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 2) Kafka commitId: 18a913733fb71c01 2020-06-25 14:03:14,216 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 2) Kafka startTimeMs: 1593093794201 2020-06-25 14:03:14,216 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 3) Kafka version: 2.3.1 2020-06-25 14:03:14,216 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 3) Kafka commitId: 18a913733fb71c01 2020-06-25 14:03:14,216 INFO [org.apa.kaf.com.uti.AppInfoParser] (SiteWhere MQTT(json - SiteWhere/default/input/json) Processor 3) Kafka startTimeMs: 1593093794200 2020-06-25 14:03:14,247 INFO [org.apa.kaf.cli.Metadata] (kafka-producer-network-thread | producer-2) [Producer clientId=producer-2] Cluster ID: avTEDTNzS8OpkDiIzOvmIA 2020-06-25 14:03:14,251 INFO [org.apa.kaf.cli.Metadata] (kafka-producer-network-thread | producer-1) [Producer clientId=producer-1] Cluster ID: avTEDTNzS8OpkDiIzOvmIA 2020-06-25 14:03:14,247 INFO [org.apa.kaf.cli.Metadata] (kafka-producer-network-thread | producer-3) [Producer clientId=producer-3] Cluster ID: avTEDTNzS8OpkDiIzOvmIA

sitewhere-iot commented 4 years ago

image