2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-29 13:00:03 +00:00

Fix subscription handling for the discovery api

This commit is contained in:
Jarrod Johnson 2022-11-03 09:58:57 -04:00
parent 1e78f11c2b
commit f1a0d22fe5

View File

@ -79,6 +79,7 @@ import confluent.messages as msg
import confluent.networking.macmap as macmap
import confluent.noderange as noderange
import confluent.util as util
import json
import eventlet
import traceback
import shlex
@ -430,7 +431,8 @@ def get_subscriptions():
if dst:
return json.loads(dst)
except Exception:
return {}
pass
return {}
def save_subscriptions(subs):
with open('/etc/confluent/discovery_subscriptions.json', 'w') as dso: