设置Python KafkaProducer sasl机制属性

Question

我们使用的sasl机制是SCRAM-SHA-256，但是kafka生产者只接受sasl_mechanism作为PLAIN，GSSAPI，OAUTHBEARER

下面的配置将给出错误

sasl_mechanism must be in PLAIN, GSSAPI, OAUTHBEARER

配置

^{pr2}$

我需要知道如何指定正确的sasl机制。在

谢谢

Answer 1

据我所知，您使用的是^{}客户机。从source code可以看出，sasl_mechanism='SCRAM-SHA-256'不是一个有效的选项：

    """
    ...
    sasl_mechanism (str): Authentication mechanism when security_protocol
        is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are:
        PLAIN, GSSAPI, OAUTHBEARER.
    ...
    """

    if self.config['security_protocol'] in ('SASL_PLAINTEXT', 'SASL_SSL'):
        assert self.config['sasl_mechanism'] in self.SASL_MECHANISMS, (
            'sasl_mechanism must be in ' + ', '.join(self.SASL_MECHANISMS)) 

一种快速解决方法是使用支持sasl_mechanism='SCRAM-SHA-256'的^{}客户机：

^{pr2}$