From 17d603cf6655198fa61873e4d715889998a92b69 Mon Sep 17 00:00:00 2001 From: Remigiusz Janeczek Date: Fri, 18 Mar 2022 12:58:16 +0100 Subject: [KAFKA] Fix Kafka Client parameters cache reference Issue-ID: DMAAP-1705 Signed-off-by: Remigiusz Janeczek Change-Id: I843d808875afa21499109dd388d85064c62c9bc5 --- robotframework-onap/ONAPLibrary/KafkaKeywords.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'robotframework-onap') diff --git a/robotframework-onap/ONAPLibrary/KafkaKeywords.py b/robotframework-onap/ONAPLibrary/KafkaKeywords.py index 2ebb902..066d2fb 100644 --- a/robotframework-onap/ONAPLibrary/KafkaKeywords.py +++ b/robotframework-onap/ONAPLibrary/KafkaKeywords.py @@ -1,5 +1,6 @@ # Copyright 2019 AT&T Intellectual Property. All rights reserved. # Copyright (C) 2022 Nordix Foundation +# Copyright (C) 2022 Nokia # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -36,8 +37,8 @@ class KafkaKeywords(object): """connect to the specified kafka server""" client = { "bootstrap_servers": kafka_host, - "sasl_plain_username": sasl_user, - "sasl_plain_password": sasl_password, + "sasl_username": sasl_user, + "sasl_password": sasl_password, "security_protocol": 'SASL_PLAINTEXT', "ssl_context": ssl.create_default_context(), "sasl_mechanism": sasl_mechanism -- cgit 1.2.3-korg