Experimental Physics and
Industrial Control System

Hi Kay,

For alarms, you can export/import the configuration, but the tools are not compatible at runtime because we moved from RDB+JMS to Kafka.

For setup, see https://github.com/ControlSystemStudio/phoebus/tree/master/app/alarm

Thanks for these reference documentations. I can built new archive engine and alarm server from Phoebus source code and so, I built archive engine service and alarm server service.

But there is a problem with alarm server service or maybe with Kafka. Phoebus can connect to alarm server with Accelerator config, but after 30 second, the connection is failed and "No Alarm Server Connection" text appears and my saved messages with key in JSON format in Kafka doesn't appear in Phoebus Alarm UI tools.

And I'm sending the command for messages and I attached outputs of Zookeeper, Kafka and Phoebus (outputKafka.txt, outputZooKeeper.txt, outputPhoebus.txt).

commands for messages:

$ echo 'config:/Accelerator/Vacuum/TARLA:deneme,{"user":"osiloskop", "host":"alarm_server", "description"="deneme", "delay"=2, "count"=2}' | kafka/bin/kafka-console-producer.sh --broker-list 192.168.56.10:9092 --topic Accelerator --property parse.key=true --property key.separator=,

$ kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.56.10:9092 --topic Accelerator --from-beginning --property print.key=true --property key.separator=,

-- 
Hasan Sansar

[2021-09-16 10:23:47,608] INFO [Partition __consumer_offsets-41 broker=0] __consumer_offsets-41 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition)
[2021-09-16 10:23:47,626] INFO Replica loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Replica)
[2021-09-16 10:23:47,627] INFO [Partition __consumer_offsets-32 broker=0] __consumer_offsets-32 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition)
[2021-09-16 10:23:47,647] INFO Replica loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Replica)
[2021-09-16 10:23:47,647] INFO [Partition __consumer_offsets-3 broker=0] __consumer_offsets-3 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition)
[2021-09-16 10:23:47,665] INFO Replica loaded for partition __consumer_offsets-13 with initial high watermark 16 (kafka.cluster.Replica)
[2021-09-16 10:23:47,665] INFO [Partition __consumer_offsets-13 broker=0] __consumer_offsets-13 starts at Leader Epoch 0 from offset 16. Previous Leader Epoch was: -1 (kafka.cluster.Partition)
[2021-09-16 10:23:47,694] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,696] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,697] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,698] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,698] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,698] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,698] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,714] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,714] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,714] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,715] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,753] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-22 in 55 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,806] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-68ba3ca8-06bb-4cd5-b86f-d57e204524b1 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,813] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-2fbcd21f-1d16-4966-a135-0e18c58230fe with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,814] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-25 in 52 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,817] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-16c01cc3-f4aa-4afd-8711-56fea6ca81a1 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,817] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-28 in 3 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,818] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-31 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,818] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-34 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,823] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-37 in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,827] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-dd8d2860-4a3d-4ecb-b4a4-d9c3809e2929 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,827] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-40 in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,827] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-43 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,834] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-160b7239-928b-4351-997a-bd9002e1c990 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,834] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-46 in 7 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,835] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-49 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,835] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-41 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,840] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-e7a2ffcc-a9a5-48e3-ad25-545911c6fa42 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,840] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-44 in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,847] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-47 in 7 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,848] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-1 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,860] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-99917854-6462-407f-a7fe-ba28e4499e5b with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,860] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-4 in 12 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,866] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-7 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,869] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-3c508233-1048-4369-8daa-d126654b13ca with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,869] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-10 in 3 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,874] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-fc2b41a3-96ce-486f-a43d-04427e05ffab with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,874] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-13 in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,880] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-bf953f6a-45f8-4e6a-9a0a-a5ac84ba8d7d with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,880] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-16 in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,881] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-19 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,887] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-5 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,887] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-8 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,891] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-d57ec39b-9c35-405c-8215-9d553a9ddc2d with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,891] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-11 in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,897] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-7e31750d-c4b8-4f92-be61-ffac40e2c40d with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,897] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-1de8503d-1b0a-4761-8ef3-f2ec1c213fea with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,897] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-14 in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,908] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-fe8d5578-acef-4df7-9dad-ad26549dbde1 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,908] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-17 in 10 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,916] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-8140e52b-47e5-4a30-ac96-1f018d9ee23e with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,916] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-20 in 8 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,916] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-23 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,916] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-26 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,917] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-29 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,923] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-5706555d-6892-44ae-969b-3adc70d0edda with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,924] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-2 in 7 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,924] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-35 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,934] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-3f2c9a30-c8a7-4887-82ea-1ef4f4bde2a5 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,934] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-38 in 10 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,935] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-32 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,946] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-a40ce3bd-347b-423d-ab97-7ce2b708b859 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,946] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-0 in 11 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,946] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-3 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,949] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-66d1c842-a2b1-4ddd-bf5a-739df5cc8857 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,950] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-26eb4615-c93c-4ff9-a055-8c5ec61f3726 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,950] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-6 in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,950] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-9 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,952] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-12 in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,952] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-15 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,984] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-fcb6a4dd-20e4-4d3e-b6d5-ae950fc8f890 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,984] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-b74136ae-5d20-406f-9234-becc05320e17 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,984] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-c5077d88-ddb5-43d1-bbd3-a6ca340c82fa with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,984] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-18 in 32 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,988] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-0c97e3c0-f938-4bd8-8c69-4791d111559b with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,988] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-069fcd06-bb28-4719-9885-f015c08d622c with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,988] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-21 in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,988] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-24 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,991] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-42c92532-b0a4-4659-b913-3be4c9cfcbeb with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,991] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-e7e1e0da-c758-414a-b030-c9a47ce9b051 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:47,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-27 in 3 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,992] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-30 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:47,992] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-33 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:48,006] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-cb9c1fb7-dab2-4e22-87f6-1f668694b7dc with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:48,006] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-36 in 14 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:48,008] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-5b1ed0db-0234-4f0c-83e3-1f0f0bf164c2 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:48,008] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-39 in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:48,010] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-c596a2d3-5b8b-4028-b3cc-cdd978014001 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:48,010] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-42 in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:48,011] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-45 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:23:48,016] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-39aafece-e35a-4de3-bdcf-8abeab6b2bc6 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:48,017] INFO [GroupCoordinator 0]: Loading group metadata for Alarm-9a677594-1b04-41fd-8d9a-3f4b7cf3e627 with generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:23:48,017] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-48 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:25:40,856] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-37d3f493-8038-4bbd-8a65-c4bff1a3dd21 in state PreparingRebalance with old generation 0 (__consumer_offsets-33) (reason: Adding new member consumer-45-d3f1e04b-04c8-4173-8cc4-0cbc74f5d8cf with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:25:40,889] INFO [GroupCoordinator 0]: Stabilized group Alarm-37d3f493-8038-4bbd-8a65-c4bff1a3dd21 generation 1 (__consumer_offsets-33) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:25:40,901] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-37d3f493-8038-4bbd-8a65-c4bff1a3dd21 for generation 1 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:27:30,975] INFO [GroupCoordinator 0]: Member consumer-45-d3f1e04b-04c8-4173-8cc4-0cbc74f5d8cf in group Alarm-37d3f493-8038-4bbd-8a65-c4bff1a3dd21 has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:27:30,976] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-37d3f493-8038-4bbd-8a65-c4bff1a3dd21 in state PreparingRebalance with old generation 1 (__consumer_offsets-33) (reason: removing member consumer-45-d3f1e04b-04c8-4173-8cc4-0cbc74f5d8cf on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:27:30,977] INFO [GroupCoordinator 0]: Group Alarm-37d3f493-8038-4bbd-8a65-c4bff1a3dd21 with generation 2 is now empty (__consumer_offsets-33) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:33:46,018] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 13 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:43:46,009] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 10:51:42,591] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-7fc08ff9-365b-4155-a5cd-8309c3802a4e in state PreparingRebalance with old generation 0 (__consumer_offsets-43) (reason: Adding new member consumer-46-9f614ec7-2a9f-4a00-a33c-d236da5c8066 with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:51:42,592] INFO [GroupCoordinator 0]: Stabilized group Alarm-7fc08ff9-365b-4155-a5cd-8309c3802a4e generation 1 (__consumer_offsets-43) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:51:42,605] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-7fc08ff9-365b-4155-a5cd-8309c3802a4e for generation 1 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:17,750] INFO [GroupCoordinator 0]: Member consumer-46-9f614ec7-2a9f-4a00-a33c-d236da5c8066 in group Alarm-7fc08ff9-365b-4155-a5cd-8309c3802a4e has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:17,751] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-7fc08ff9-365b-4155-a5cd-8309c3802a4e in state PreparingRebalance with old generation 1 (__consumer_offsets-43) (reason: removing member consumer-46-9f614ec7-2a9f-4a00-a33c-d236da5c8066 on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:17,751] INFO [GroupCoordinator 0]: Group Alarm-7fc08ff9-365b-4155-a5cd-8309c3802a4e with generation 2 is now empty (__consumer_offsets-43) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:17,913] INFO Creating topic Demo with configuration {} and initial partition assignment Map(0 -> ArrayBuffer(0)) (kafka.zk.AdminZkClient)
[2021-09-16 10:52:17,968] INFO [KafkaApi-0] Auto creation of topic Demo with 1 partitions and replication factor 1 is successful (kafka.server.KafkaApis)
[2021-09-16 10:52:17,999] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 in state PreparingRebalance with old generation 0 (__consumer_offsets-46) (reason: Adding new member consumer-47-c0910b1b-e4ed-4272-a8cb-5d4184f5aefc with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:18,000] INFO [GroupCoordinator 0]: Stabilized group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 generation 1 (__consumer_offsets-46) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:18,079] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(Demo-0) (kafka.server.ReplicaFetcherManager)
[2021-09-16 10:52:18,084] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 for generation 1 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:18,083] INFO [Log partition=Demo-0, dir=/var/log/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log)
[2021-09-16 10:52:18,088] INFO [Log partition=Demo-0, dir=/var/log/kafka-logs] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log)
[2021-09-16 10:52:18,089] INFO Created log for partition Demo-0 in /var/log/kafka-logs with properties {compression.type -> producer, min.insync.replicas -> 1, message.downconversion.enable -> true, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, retention.ms -> 604800000, segment.bytes -> 1073741824, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, max.compaction.lag.ms -> 9223372036854775807, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, index.interval.bytes -> 4096, min.cleanable.dirty.ratio -> 0.5, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager)
[2021-09-16 10:52:18,091] INFO [Partition Demo-0 broker=0] No checkpointed highwatermark is found for partition Demo-0 (kafka.cluster.Partition)
[2021-09-16 10:52:18,092] INFO Replica loaded for partition Demo-0 with initial high watermark 0 (kafka.cluster.Replica)
[2021-09-16 10:52:18,092] INFO [Partition Demo-0 broker=0] Demo-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition)
[2021-09-16 10:52:18,193] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 in state PreparingRebalance with old generation 1 (__consumer_offsets-46) (reason: Updating metadata for member consumer-47-c0910b1b-e4ed-4272-a8cb-5d4184f5aefc) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:18,217] INFO [GroupCoordinator 0]: Stabilized group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 generation 2 (__consumer_offsets-46) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:18,231] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 for generation 2 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:44,216] INFO [GroupCoordinator 0]: Member consumer-47-c0910b1b-e4ed-4272-a8cb-5d4184f5aefc in group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:44,216] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 in state PreparingRebalance with old generation 2 (__consumer_offsets-46) (reason: removing member consumer-47-c0910b1b-e4ed-4272-a8cb-5d4184f5aefc on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:44,216] INFO [GroupCoordinator 0]: Group Alarm-ec2fb1e9-0c3e-4740-9b94-de0a8be54713 with generation 3 is now empty (__consumer_offsets-46) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:44,380] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-566cd3da-6ac8-463f-8be1-81fc7d0b221d in state PreparingRebalance with old generation 0 (__consumer_offsets-17) (reason: Adding new member consumer-48-cd0831f4-e67b-43da-89ab-060d8940d391 with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:44,382] INFO [GroupCoordinator 0]: Stabilized group Alarm-566cd3da-6ac8-463f-8be1-81fc7d0b221d generation 1 (__consumer_offsets-17) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:52:44,386] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-566cd3da-6ac8-463f-8be1-81fc7d0b221d for generation 1 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 10:53:46,008] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 3 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 11:03:46,009] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 11:13:46,007] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2021-09-16 11:16:19,844] INFO [Log partition=Accelerator-0, dir=/var/log/kafka-logs] Rolled new log segment at offset 308 in 3 ms. (kafka.log.Log)
[2021-09-16 11:16:51,197] INFO [GroupCoordinator 0]: Member consumer-48-cd0831f4-e67b-43da-89ab-060d8940d391 in group Alarm-566cd3da-6ac8-463f-8be1-81fc7d0b221d has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:16:51,198] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-566cd3da-6ac8-463f-8be1-81fc7d0b221d in state PreparingRebalance with old generation 1 (__consumer_offsets-17) (reason: removing member consumer-48-cd0831f4-e67b-43da-89ab-060d8940d391 on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:16:51,198] INFO [GroupCoordinator 0]: Group Alarm-566cd3da-6ac8-463f-8be1-81fc7d0b221d with generation 2 is now empty (__consumer_offsets-17) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:16:58,719] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-fcc958ca-1ef1-414a-bfe2-922c014f52e9 in state PreparingRebalance with old generation 0 (__consumer_offsets-42) (reason: Adding new member consumer-49-2e00e453-0bea-4554-a931-794fff0d672b with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:16:58,720] INFO [GroupCoordinator 0]: Stabilized group Alarm-fcc958ca-1ef1-414a-bfe2-922c014f52e9 generation 1 (__consumer_offsets-42) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:16:58,744] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-fcc958ca-1ef1-414a-bfe2-922c014f52e9 for generation 1 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:03,667] INFO [GroupCoordinator 0]: Member consumer-49-2e00e453-0bea-4554-a931-794fff0d672b in group Alarm-fcc958ca-1ef1-414a-bfe2-922c014f52e9 has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:03,667] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-fcc958ca-1ef1-414a-bfe2-922c014f52e9 in state PreparingRebalance with old generation 1 (__consumer_offsets-42) (reason: removing member consumer-49-2e00e453-0bea-4554-a931-794fff0d672b on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:03,667] INFO [GroupCoordinator 0]: Group Alarm-fcc958ca-1ef1-414a-bfe2-922c014f52e9 with generation 2 is now empty (__consumer_offsets-42) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:08,092] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-73f6bb2a-e2af-43a8-80fe-f79d4906db43 in state PreparingRebalance with old generation 0 (__consumer_offsets-46) (reason: Adding new member consumer-50-ca0d1496-80de-4880-8c6b-089dabe80139 with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:08,093] INFO [GroupCoordinator 0]: Stabilized group Alarm-73f6bb2a-e2af-43a8-80fe-f79d4906db43 generation 1 (__consumer_offsets-46) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:08,100] INFO [GroupCoordinator 0]: Assignment received from leader for group Alarm-73f6bb2a-e2af-43a8-80fe-f79d4906db43 for generation 1 (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:30,973] INFO [Log partition=Accelerator-0, dir=/var/log/kafka-logs] Deleting segment 0 (kafka.log.Log)
[2021-09-16 11:17:30,978] INFO [Log partition=Accelerator-0, dir=/var/log/kafka-logs] Deleting segment 306 (kafka.log.Log)
[2021-09-16 11:17:30,990] INFO Deleted log /var/log/kafka-logs/Accelerator-0/00000000000000000000.log.deleted. (kafka.log.LogSegment)
[2021-09-16 11:17:30,993] INFO Deleted offset index /var/log/kafka-logs/Accelerator-0/00000000000000000000.index.deleted. (kafka.log.LogSegment)
[2021-09-16 11:17:30,994] INFO Deleted time index /var/log/kafka-logs/Accelerator-0/00000000000000000000.timeindex.deleted. (kafka.log.LogSegment)
[2021-09-16 11:17:30,991] INFO Deleted log /var/log/kafka-logs/Accelerator-0/00000000000000000306.log.deleted. (kafka.log.LogSegment)
[2021-09-16 11:17:30,995] INFO Deleted offset index /var/log/kafka-logs/Accelerator-0/00000000000000000306.index.deleted. (kafka.log.LogSegment)
[2021-09-16 11:17:30,995] INFO Deleted time index /var/log/kafka-logs/Accelerator-0/00000000000000000306.timeindex.deleted. (kafka.log.LogSegment)
[2021-09-16 11:17:41,358] INFO [GroupCoordinator 0]: Member consumer-50-ca0d1496-80de-4880-8c6b-089dabe80139 in group Alarm-73f6bb2a-e2af-43a8-80fe-f79d4906db43 has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:41,358] INFO [GroupCoordinator 0]: Preparing to rebalance group Alarm-73f6bb2a-e2af-43a8-80fe-f79d4906db43 in state PreparingRebalance with old generation 1 (__consumer_offsets-46) (reason: removing member consumer-50-ca0d1496-80de-4880-8c6b-089dabe80139 on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:17:41,358] INFO [GroupCoordinator 0]: Group Alarm-73f6bb2a-e2af-43a8-80fe-f79d4906db43 with generation 2 is now empty (__consumer_offsets-46) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:23:16,682] INFO [GroupCoordinator 0]: Preparing to rebalance group console-consumer-34775 in state PreparingRebalance with old generation 0 (__consumer_offsets-17) (reason: Adding new member consumer-1-3046e7f3-19e7-441c-807e-aa6dea770e20 with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
[2021-09-16 11:23:16,684] INFO [GroupCoordinator 0]: Stabilized group console-consumer-34775 generation 1 (__consumer_offsets-17) (kafka.coordinator.group.GroupCoordinator)

05:57:03.320 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:03.824 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:03.824 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:03.824 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=36) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:03.824 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:04.327 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:04.327 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:04.328 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=37) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:04.328 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:04.764 [kafka-coordinator-heartbeat-thread | Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending Heartbeat request to coordinator 192.168.56.10:9092 (id: 2147483647 rack: null)
05:57:04.765 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Received successful Heartbeat response
05:57:04.832 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:04.832 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:04.832 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=38) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:04.832 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:05.335 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:05.335 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:05.335 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=39) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:05.335 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:05.838 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:05.838 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:05.838 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=40) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:05.838 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:06.340 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:06.340 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:06.340 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=41) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:06.341 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:06.644 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending asynchronous auto-commit of offsets {Accelerator-0=OffsetAndMetadata{offset=310, metadata=''}}
05:57:06.647 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Committed offset 310 for partition Accelerator-0
05:57:06.647 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Completed asynchronous auto-commit of offsets {Accelerator-0=OffsetAndMetadata{offset=310, metadata=''}}
05:57:06.843 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:06.844 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:06.844 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=42) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:06.844 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:07.347 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:07.347 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:07.347 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=43) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:07.347 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:07.780 [kafka-coordinator-heartbeat-thread | Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending Heartbeat request to coordinator 192.168.56.10:9092 (id: 2147483647 rack: null)
05:57:07.782 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Received successful Heartbeat response
05:57:07.850 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:07.851 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:07.851 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=44) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:07.851 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:08.354 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:08.354 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:08.354 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=45) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:08.354 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:08.858 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:08.858 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:08.858 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=46) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:08.858 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:09.361 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:09.361 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:09.361 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=47) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:09.361 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:09.864 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:09.865 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:09.865 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=48) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:09.865 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:10.367 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:10.367 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:10.367 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=49) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:10.367 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:10.799 [kafka-coordinator-heartbeat-thread | Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending Heartbeat request to coordinator 192.168.56.10:9092 (id: 2147483647 rack: null)
05:57:10.801 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Received successful Heartbeat response
05:57:10.871 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:10.871 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:10.871 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=50) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:10.871 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:11.374 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:11.375 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:11.375 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=51) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:11.375 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:11.644 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending asynchronous auto-commit of offsets {Accelerator-0=OffsetAndMetadata{offset=310, metadata=''}}
05:57:11.648 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Committed offset 310 for partition Accelerator-0
05:57:11.648 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Completed asynchronous auto-commit of offsets {Accelerator-0=OffsetAndMetadata{offset=310, metadata=''}}
05:57:11.878 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:11.878 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:11.879 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=52) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:11.879 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:12.382 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:12.382 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:12.382 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=53) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:12.382 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:12.885 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:12.885 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:12.885 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=54) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:12.885 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:13.388 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:13.389 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:13.389 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=55) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:13.389 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:13.816 [kafka-coordinator-heartbeat-thread | Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending Heartbeat request to coordinator 192.168.56.10:9092 (id: 2147483647 rack: null)
05:57:13.817 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Received successful Heartbeat response
05:57:13.892 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:13.893 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:13.893 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=56) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:13.893 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:14.396 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:14.397 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:14.397 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=57) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:14.397 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:14.900 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:14.900 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:14.900 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=58) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:14.900 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:15.403 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:15.403 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:15.403 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=59) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:15.404 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:15.907 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:15.907 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:15.907 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=60) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:15.907 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:16.410 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:16.411 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:16.411 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=61) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:16.411 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:16.644 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending asynchronous auto-commit of offsets {Accelerator-0=OffsetAndMetadata{offset=310, metadata=''}}
05:57:16.647 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Committed offset 310 for partition Accelerator-0
05:57:16.647 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Completed asynchronous auto-commit of offsets {Accelerator-0=OffsetAndMetadata{offset=310, metadata=''}}
05:57:16.816 [kafka-coordinator-heartbeat-thread | Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending Heartbeat request to coordinator 192.168.56.10:9092 (id: 2147483647 rack: null)
05:57:16.818 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Received successful Heartbeat response
05:57:16.914 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:16.914 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:16.914 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=62) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:16.914 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:17.418 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:17.418 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:17.418 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=63) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:17.418 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:17.921 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:17.921 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:17.921 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=64) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
05:57:17.921 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(Accelerator-0)) to broker 192.168.56.10:9092 (id: 0 rack: null)
05:57:18.424 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Node 0 sent an incremental fetch response for session 146171136 with 0 response partition(s), 1 implied partition(s)
05:57:18.425 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Added READ_UNCOMMITTED fetch request for partition Accelerator-0 at offset 310 to node 192.168.56.10:9092 (id: 0 rack: null)
05:57:18.425 [AlarmClientModel Accelerator] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-55, groupId=Alarm-d92f09c7-8fcd-455c-821b-ea18e13772dc] Built incremental fetch (sessionId=146171136, epoch=65) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)

[2021-09-16 10:23:34,017] INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-09-16 10:23:42,324] INFO Accepted socket connection from /0:0:0:0:0:0:0:1:51710 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-09-16 10:23:42,341] INFO Client attempting to establish new session at /0:0:0:0:0:0:0:1:51710 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-09-16 10:23:42,346] INFO Creating new log file: log.16c (org.apache.zookeeper.server.persistence.FileTxnLog)
[2021-09-16 10:23:42,374] INFO Established session 0x1000083a3db0000 with negotiated timeout 6000 for client /0:0:0:0:0:0:0:1:51710 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-09-16 10:23:42,468] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x1 zxid:0x16d txntype:-1 reqpath:n/a Error Path:/consumers Error:KeeperErrorCode = NodeExists for /consumers (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,493] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x2 zxid:0x16e txntype:-1 reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,502] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x3 zxid:0x16f txntype:-1 reqpath:n/a Error Path:/brokers/topics Error:KeeperErrorCode = NodeExists for /brokers/topics (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,509] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x4 zxid:0x170 txntype:-1 reqpath:n/a Error Path:/config/changes Error:KeeperErrorCode = NodeExists for /config/changes (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,519] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x5 zxid:0x171 txntype:-1 reqpath:n/a Error Path:/admin/delete_topics Error:KeeperErrorCode = NodeExists for /admin/delete_topics (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,529] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x6 zxid:0x172 txntype:-1 reqpath:n/a Error Path:/brokers/seqid Error:KeeperErrorCode = NodeExists for /brokers/seqid (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,539] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x7 zxid:0x173 txntype:-1 reqpath:n/a Error Path:/isr_change_notification Error:KeeperErrorCode = NodeExists for /isr_change_notification (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,550] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x8 zxid:0x174 txntype:-1 reqpath:n/a Error Path:/latest_producer_id_block Error:KeeperErrorCode = NodeExists for /latest_producer_id_block (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,560] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0x9 zxid:0x175 txntype:-1 reqpath:n/a Error Path:/log_dir_event_notification Error:KeeperErrorCode = NodeExists for /log_dir_event_notification (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,571] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0xa zxid:0x176 txntype:-1 reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,581] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0xb zxid:0x177 txntype:-1 reqpath:n/a Error Path:/config/clients Error:KeeperErrorCode = NodeExists for /config/clients (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,588] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0xc zxid:0x178 txntype:-1 reqpath:n/a Error Path:/config/users Error:KeeperErrorCode = NodeExists for /config/users (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:42,599] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:create cxid:0xd zxid:0x179 txntype:-1 reqpath:n/a Error Path:/config/brokers Error:KeeperErrorCode = NodeExists for /config/brokers (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:23:46,678] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:multi cxid:0x6f zxid:0x17d txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:28:53,000] INFO Accepted socket connection from /127.0.0.1:34530 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-09-16 10:28:53,004] INFO Client attempting to establish new session at /127.0.0.1:34530 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-09-16 10:28:53,015] INFO Established session 0x1000083a3db0001 with negotiated timeout 30000 for client /127.0.0.1:34530 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-09-16 10:28:53,101] INFO Processed session termination for sessionid: 0x1000083a3db0001 (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 10:28:53,143] INFO Closed socket connection for client /127.0.0.1:34530 which had sessionid 0x1000083a3db0001 (org.apache.zookeeper.server.NIOServerCnxn)
[2021-09-16 10:52:17,918] INFO Got user-level KeeperException when processing sessionid:0x1000083a3db0000 type:setData cxid:0xac zxid:0x180 txntype:-1 reqpath:n/a Error Path:/config/topics/Demo Error:KeeperErrorCode = NoNode for /config/topics/Demo (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 11:13:37,145] INFO Accepted socket connection from /127.0.0.1:40570 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-09-16 11:13:37,150] INFO Client attempting to establish new session at /127.0.0.1:40570 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-09-16 11:13:37,158] INFO Established session 0x1000083a3db0002 with negotiated timeout 30000 for client /127.0.0.1:40570 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-09-16 11:13:37,527] INFO Processed session termination for sessionid: 0x1000083a3db0002 (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-09-16 11:13:37,537] INFO Closed socket connection for client /127.0.0.1:40570 which had sessionid 0x1000083a3db0002 (org.apache.zookeeper.server.NIOServerCnxn)

Replies:

Re: [EXTERNAL] Alarm Server and archiveEngine Hasan SANSAR via Tech-talk

References:

Alarm Server and archiveEngine Hasan SANSAR via Tech-talk

Re: [EXTERNAL] Alarm Server and archiveEngine Kasemir, Kay via Tech-talk

Re: [EXTERNAL] Alarm Server and archiveEngine Hasan SANSAR via Tech-talk

Re: [EXTERNAL] Alarm Server and archiveEngine Kasemir, Kay via Tech-talk

Navigate by Date:

Prev: RE: SynApps sscan record: timestamp issue for BUSY DATA and EXSC fields; causing problem archiving with Phoebus Archive engine Mark Rivers via Tech-talk

Next: Re: [EXTERNAL] Alarm Server and archiveEngine Hasan SANSAR via Tech-talk

Index: 1994  1995  1996  1997  1998  1999  2000  2001  2002  2003  2004  2005  2006  2007  2008  2009  2010  2011  2012  2013  2014  2015  2016  2017  2018  2019  2020  <2021>  2022  2023  2024 

Navigate by Thread:

Prev: Re: [EXTERNAL] Alarm Server and archiveEngine Kasemir, Kay via Tech-talk

Next: Re: [EXTERNAL] Alarm Server and archiveEngine Hasan SANSAR via Tech-talk

Index: 1994  1995  1996  1997  1998  1999  2000  2001  2002  2003  2004  2005  2006  2007  2008  2009  2010  2011  2012  2013  2014  2015  2016  2017  2018  2019  2020  <2021>  2022  2023  2024