![]() ![]() 12:49:22,154 INFO c.l.k.ConsumerGroupCollector$ akka://kafka-lag-exporter/user/consumer-group-collector-local - Reporting offsets 12:49:22,147 INFO c.l.k.ConsumerGroupCollector$ akka://kafka-lag-exporter/user/consumer-group-collector-local - Updating lookup tables 12:49:22,140 DEBUG c.l.k.ConsumerGroupCollector$ akka://kafka-lag-exporter/user/consumer-group-collector-local - Received Offsets Snapshot: 12:49:20,599 INFO c.l.k.ConsumerGroupCollector$ akka://kafka-lag-exporter/user/consumer-group-collector-local - Collecting offsets 12:49:20,581 INFO o.a. akka://kafka-lag-exporter/user/consumer-group-collector-local - Kafka version: 2.5.0 12:49:20,527 INFO o.a.k.c.admin.AdminClientConfig akka://kafka-lag-exporter/user/consumer-group-collector-local - AdminClientConfig values: 12:49:20,511 INFO o.a. akka://kafka-lag-exporter/user/consumer-group-collector-local - Kafka version: 2.5.0 serializer = class .serialization.ByteArrayDeserializer ![]() Key.deserializer = class .serialization.ByteArrayDeserializer 12:49:20,218 INFO o.a.k.c.consumer.ConsumerConfig akka://kafka-lag-exporter/user/consumer-group-collector-local - ConsumerConfig values: 12:49:20,156 INFO c.l.k.ConsumerGroupCollector$ akka://kafka-lag-exporter/user/consumer-group-collector-local - Spawned ConsumerGroupCollector for cluster: local 12:49:20,142 INFO c.l.k.KafkaClusterManager$ akka://kafka-lag-exporter/user - Cluster Added: 12:49:19,994 INFO c.l.k.KafkaClusterManager$ akka://kafka-lag-exporter/user - Starting Kafka Lag Exporter with configuration:Īdmin client consumer group id: kafkalagexporterĬluster Kafka bootstrap brokers: kafka:9092 12:49:19,839 INFO 4jLogger - Slf4jLogger started
0 Comments
Leave a Reply. |