[main] INFO org.opendaylight.transportpce.common.network.RequestProcessor - RequestProcessor instantiated [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - RPC getNotificationsAlarmService received [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Subscribing for group id groupId, client config id consumerId with properties {key.deserializer=class org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=class org.opendaylight.transportpce.nbinotifications.serialization.NotificationAlarmServiceDeserializer, enable.auto.commit=false, group.id=groupId, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@21624da5, bootstrap.servers=localhost:8080, auto.commit.interval.ms=1000, auto.offset.reset=earliest, client.id=consumerId} [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 1000 auto.offset.reset = earliest bootstrap.servers = [localhost:8080] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumerId client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = groupId group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.opendaylight.transportpce.nbinotifications.serialization.NotificationAlarmServiceDeserializer [main] INFO org.opendaylight.transportpce.nbinotifications.serialization.NotificationAlarmServiceDeserializer - Deserializer configuration {key.deserializer=class org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=class org.opendaylight.transportpce.nbinotifications.serialization.NotificationAlarmServiceDeserializer, enable.auto.commit=false, group.id=groupId, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@21624da5, bootstrap.servers=localhost:8080, auto.commit.interval.ms=1000, auto.offset.reset=earliest, client.id=consumerId} [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.0.0 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 8cb0a5e9d3441962 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1706546445443 [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Subscribe request to topic 'alarmservice' [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumerId, groupId=groupId] Subscribed to topic(s): alarmservice [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Getting records '[]' [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Resetting generation due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Request joining group due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumerId, groupId=groupId] Unsubscribed all topics or patterns and assigned partitions [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Resetting generation due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Request joining group due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed [main] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed [main] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.consumer for consumerId unregistered [main] INFO org.opendaylight.transportpce.common.network.RequestProcessor - RequestProcessor instantiated [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - RPC getNotificationsService received [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Subscribing for group id groupId, client config id consumerId with properties {key.deserializer=class org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=class org.opendaylight.transportpce.nbinotifications.serialization.NotificationServiceDeserializer, enable.auto.commit=false, group.id=groupId, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@d573ad4, bootstrap.servers=localhost:8080, auto.commit.interval.ms=1000, auto.offset.reset=earliest, client.id=consumerId} [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 1000 auto.offset.reset = earliest bootstrap.servers = [localhost:8080] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumerId client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = groupId group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.opendaylight.transportpce.nbinotifications.serialization.NotificationServiceDeserializer [main] INFO org.opendaylight.transportpce.nbinotifications.serialization.NotificationServiceDeserializer - Deserializer configuration {key.deserializer=class org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=class org.opendaylight.transportpce.nbinotifications.serialization.NotificationServiceDeserializer, enable.auto.commit=false, group.id=groupId, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@d573ad4, bootstrap.servers=localhost:8080, auto.commit.interval.ms=1000, auto.offset.reset=earliest, client.id=consumerId} [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.0.0 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 8cb0a5e9d3441962 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1706546446481 [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Subscribe request to topic 'service' [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumerId, groupId=groupId] Subscribed to topic(s): service [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumerId, groupId=groupId] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Getting records '[]' [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Resetting generation due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Request joining group due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumerId, groupId=groupId] Unsubscribed all topics or patterns and assigned partitions [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Resetting generation due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumerId, groupId=groupId] Request joining group due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed [main] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed [main] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.consumer for consumerId unregistered [main] INFO org.opendaylight.transportpce.common.network.RequestProcessor - RequestProcessor instantiated [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Adding T-API topic: c3b97a56-489f-47f6-8900-1cde5eb38971 to Kafka server [main] INFO org.opendaylight.transportpce.nbinotifications.utils.TopicManager - Adding new tapi topic: c3b97a56-489f-47f6-8900-1cde5eb38971 [main] INFO org.opendaylight.transportpce.nbinotifications.producer.Publisher - Creation publisher for id c3b97a56-489f-47f6-8900-1cde5eb38971 with properties {retries=3, value.serializer=class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer, acks=all, batch.size=16384, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@6fe6bacc, bootstrap.servers=localhost:9092, max.in.flight.requests.per.connection=1, buffer.memory=33554432, key.serializer=class org.apache.kafka.common.serialization.StringSerializer, linger.ms=1, client.id=c3b97a56-489f-47f6-8900-1cde5eb38971} [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = c3b97a56-489f-47f6-8900-1cde5eb38971 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 1 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 3 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer [main] INFO org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer - Deserializer configuration {retries=3, value.serializer=class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer, acks=all, batch.size=16384, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@6fe6bacc, bootstrap.servers=localhost:9092, max.in.flight.requests.per.connection=1, buffer.memory=33554432, key.serializer=class org.apache.kafka.common.serialization.StringSerializer, linger.ms=1, client.id=c3b97a56-489f-47f6-8900-1cde5eb38971} [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.0.0 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 8cb0a5e9d3441962 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1706546447530 [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Getting tapi notification context [main] INFO org.opendaylight.transportpce.common.network.RequestProcessor - RequestProcessor instantiated [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Adding T-API topic: e30fb884-39d3-465a-8ead-51c86bcfedd5 to Kafka server [main] INFO org.opendaylight.transportpce.nbinotifications.utils.TopicManager - Adding new tapi topic: e30fb884-39d3-465a-8ead-51c86bcfedd5 [main] INFO org.opendaylight.transportpce.nbinotifications.producer.Publisher - Creation publisher for id e30fb884-39d3-465a-8ead-51c86bcfedd5 with properties {retries=3, value.serializer=class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer, acks=all, batch.size=16384, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@6c6027e9, bootstrap.servers=localhost:9092, max.in.flight.requests.per.connection=1, buffer.memory=33554432, key.serializer=class org.apache.kafka.common.serialization.StringSerializer, linger.ms=1, client.id=e30fb884-39d3-465a-8ead-51c86bcfedd5} [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = e30fb884-39d3-465a-8ead-51c86bcfedd5 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 1 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 3 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer [main] INFO org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer - Deserializer configuration {retries=3, value.serializer=class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationSerializer, acks=all, batch.size=16384, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@6c6027e9, bootstrap.servers=localhost:9092, max.in.flight.requests.per.connection=1, buffer.memory=33554432, key.serializer=class org.apache.kafka.common.serialization.StringSerializer, linger.ms=1, client.id=e30fb884-39d3-465a-8ead-51c86bcfedd5} [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.0.0 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 8cb0a5e9d3441962 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1706546447611 [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Getting tapi notification context [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - RPC getNotificationList received [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Given attribute c385735e-f40d-461c-907d-45ea6012c7e8 is a UUID [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Going to get notifications for topic e30fb884-39d3-465a-8ead-51c86bcfedd5 [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Subscribing for group id e30fb884-39d3-465a-8ead-51c86bcfedd5, client config id e30fb884-39d3-465a-8ead-51c86bcfedd5 with properties {key.deserializer=class org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationDeserializer, enable.auto.commit=false, group.id=e30fb884-39d3-465a-8ead-51c86bcfedd5, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@6c6027e9, bootstrap.servers=localhost:8080, auto.commit.interval.ms=1000, auto.offset.reset=earliest, client.id=e30fb884-39d3-465a-8ead-51c86bcfedd5} [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 1000 auto.offset.reset = earliest bootstrap.servers = [localhost:8080] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = e30fb884-39d3-465a-8ead-51c86bcfedd5 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = e30fb884-39d3-465a-8ead-51c86bcfedd5 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationDeserializer [main] INFO org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationDeserializer - Tapi Deserializer configuration {key.deserializer=class org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=class org.opendaylight.transportpce.nbinotifications.serialization.TapiNotificationDeserializer, enable.auto.commit=false, group.id=e30fb884-39d3-465a-8ead-51c86bcfedd5, converter=org.opendaylight.transportpce.common.converter.JsonStringConverter@6c6027e9, bootstrap.servers=localhost:8080, auto.commit.interval.ms=1000, auto.offset.reset=earliest, client.id=e30fb884-39d3-465a-8ead-51c86bcfedd5} [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.0.0 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 8cb0a5e9d3441962 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1706546447618 [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Subscribe request to topic 'e30fb884-39d3-465a-8ead-51c86bcfedd5' [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Subscribed to topic(s): e30fb884-39d3-465a-8ead-51c86bcfedd5 [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:8080) could not be established. Broker may not be available. [main] WARN org.apache.kafka.clients.NetworkClient - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:8080 (id: -1 rack: null) disconnected [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | e30fb884-39d3-465a-8ead-51c86bcfedd5] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. [kafka-producer-network-thread | c3b97a56-489f-47f6-8900-1cde5eb38971] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=c3b97a56-489f-47f6-8900-1cde5eb38971] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected [main] INFO org.opendaylight.transportpce.nbinotifications.consumer.Subscriber - Getting records '[]' [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Resetting generation due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Request joining group due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Unsubscribed all topics or patterns and assigned partitions [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Resetting generation due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=e30fb884-39d3-465a-8ead-51c86bcfedd5, groupId=e30fb884-39d3-465a-8ead-51c86bcfedd5] Request joining group due to: consumer pro-actively leaving the group [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed [main] INFO org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter [main] INFO org.apache.kafka.common.metrics.Metrics - Metrics reporters closed [main] INFO org.apache.kafka.common.utils.AppInfoParser - App info kafka.consumer for e30fb884-39d3-465a-8ead-51c86bcfedd5 unregistered [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - TAPI notifications = [] [main] INFO org.opendaylight.transportpce.common.network.RequestProcessor - RequestProcessor instantiated [main] INFO org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - RPC getNotificationsService received [main] WARN org.opendaylight.transportpce.nbinotifications.impl.NbiNotificationsImpl - Missing mandatory params for input GetNotificationsProcessServiceInput{}