Skip to content

Commit 13752d7

Browse files
natedogs911dpkp
authored andcommitted
Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#1264)
1 parent 52bc85d commit 13752d7

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

kafka/consumer/group.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -219,6 +219,8 @@ class KafkaConsumer(six.Iterator):
219219
Default: None
220220
sasl_plain_password (str): Password for sasl PLAIN authentication.
221221
Default: None
222+
sasl_kerberos_service_name (str): Service name to include in GSSAPI
223+
sasl mechanism handshake. Default: 'kafka'
222224
223225
Note:
224226
Configuration parameters are described in more detail at
@@ -274,6 +276,7 @@ class KafkaConsumer(six.Iterator):
274276
'sasl_mechanism': None,
275277
'sasl_plain_username': None,
276278
'sasl_plain_password': None,
279+
'sasl_kerberos_service_name': 'kafka'
277280
}
278281

279282
def __init__(self, *topics, **configs):

kafka/producer/kafka.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -263,6 +263,8 @@ class KafkaProducer(object):
263263
Default: None
264264
sasl_plain_password (str): password for sasl PLAIN authentication.
265265
Default: None
266+
sasl_kerberos_service_name (str): Service name to include in GSSAPI
267+
sasl mechanism handshake. Default: 'kafka'
266268
267269
Note:
268270
Configuration parameters are described in more detail at
@@ -309,6 +311,7 @@ class KafkaProducer(object):
309311
'sasl_mechanism': None,
310312
'sasl_plain_username': None,
311313
'sasl_plain_password': None,
314+
'sasl_kerberos_service_name': 'kafka'
312315
}
313316

314317
_COMPRESSORS = {

0 commit comments

Comments
 (0)