Fix logging startup problems

This commit is contained in:
Cyber MacGeddon 2025-07-30 23:59:45 +01:00
parent 444d205251
commit 1afdd2d026

View file

@ -21,7 +21,7 @@ class PulsarClient:
"pulsar_api_key",
self.default_pulsar_api_key
)
log_level = params.get("log_level", LogLevel.INFO)
# Hard-code Pulsar logging to ERROR level to minimize noise
self.pulsar_host = pulsar_host
self.pulsar_api_key = pulsar_api_key
@ -31,13 +31,13 @@ class PulsarClient:
self.client = pulsar.Client(
pulsar_host,
authentication=auth,
logger=pulsar.ConsoleLogger(log_level.to_pulsar())
logger=pulsar.ConsoleLogger(_pulsar.LoggerLevel.Error)
)
else:
self.client = pulsar.Client(
pulsar_host,
listener_name=pulsar_listener,
logger=pulsar.ConsoleLogger(log_level.to_pulsar())
logger=pulsar.ConsoleLogger(_pulsar.LoggerLevel.Error)
)
self.pulsar_listener = pulsar_listener