Skip to content

Commit 54746b1

Browse files
author
Naor Livne
committed
optional kafka reporter default variables changes
1 parent 9642100 commit 54746b1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

functions/reporting/kafka.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
class KafkaConnection:
66

77
def __init__(self, bootstrap_servers, security_protocol="PLAINTEXT", sasl_mechanism=None, sasl_plain_username=None,
8-
sasl_plain_password=None,
9-
ssl_keyfile=None, ssl_password=None, ssl_certfile=None, ssl_cafile=None, ssl_crlfile=None,
10-
sasl_kerberos_service_name="kafka", sasl_kerberos_domain_name="kafka", topic="nebula-reports"):
8+
sasl_plain_password=None, ssl_keyfile=None, ssl_password=None, ssl_certfile=None, ssl_cafile=None,
9+
ssl_crlfile=None, sasl_kerberos_service_name="kafka", sasl_kerberos_domain_name="kafka",
10+
topic="nebula-reports"):
1111
self.topic = topic
1212
self.producer = KafkaProducer(value_serializer=lambda m: json.dumps(m).encode('ascii'),
1313
bootstrap_servers=bootstrap_servers, security_protocol=security_protocol,

0 commit comments

Comments
 (0)