(20250612) - changed redis connection string.
This commit is contained in:
@@ -340,12 +340,9 @@ async def init(
|
|||||||
bootstrap_servers = consumer_creds["config"]["bootstrapServers"],
|
bootstrap_servers = consumer_creds["config"]["bootstrapServers"],
|
||||||
security_protocol = consumer_creds["config"].get("securityProtocol", "PLAINTEXT"),
|
security_protocol = consumer_creds["config"].get("securityProtocol", "PLAINTEXT"),
|
||||||
ssl_context = get_ssl_context(
|
ssl_context = get_ssl_context(
|
||||||
# ca_file = consumer_creds["config"].get("caFile"),
|
ca_file = consumer_creds["config"].get("caFile"),
|
||||||
# cert_file = consumer_creds["config"].get("certFile"),
|
cert_file = consumer_creds["config"].get("certFile"),
|
||||||
# key_file = consumer_creds["config"].get("keyFile"),
|
key_file = consumer_creds["config"].get("keyFile"),
|
||||||
ca_file="/home/python-dev-debug/PycharmProjects/api_utils_converse_v2/creds/kafka/cert_authority.pem",
|
|
||||||
cert_file="/home/python-dev-debug/PycharmProjects/api_utils_converse_v2/creds/kafka/fullchain.pem",
|
|
||||||
key_file="/home/python-dev-debug/PycharmProjects/api_utils_converse_v2/creds/kafka/privkey.pem",
|
|
||||||
),
|
),
|
||||||
serializer = JSONSerializer(),
|
serializer = JSONSerializer(),
|
||||||
debug = debug
|
debug = debug
|
||||||
|
|||||||
Reference in New Issue
Block a user