We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e399560 commit a341c39Copy full SHA for a341c39
bizon/connectors/sources/kafka/src/source.py
@@ -113,7 +113,7 @@ def __init__(self, config: KafkaSourceConfig):
113
114
self.config: KafkaSourceConfig = config
115
116
- # Kafka consumer configuration
+ # Kafka consumer configuration.
117
if self.config.authentication.type == AuthType.BASIC:
118
self.config.consumer_config["sasl.mechanisms"] = "PLAIN"
119
self.config.consumer_config["sasl.username"] = self.config.authentication.params.username
0 commit comments