Fix merge issues with api-key, conflicts with librarian changes

This commit is contained in:
Cyber MacGeddon 2025-02-15 12:24:19 +00:00
parent 617eb7efd5
commit 2fcbdd293f
11 changed files with 8 additions and 23 deletions

View file

@ -35,6 +35,8 @@ class BaseProcessor:
log_level = params.get("log_level", LogLevel.INFO)
self.pulsar_host = pulsar_host
self.pulsar_api_key = pulsar_api_key
if pulsar_api_key:
auth = pulsar.AuthenticationToken(pulsar_api_key)
self.client = pulsar.Client(