kafka-python:使用SASL_SSL+SCRAM-SHA-512时，在recv期间重置连接

Question

我使用kafka python使用SASL 连接到kafka集群

consumer = KafkaConsumer(bootstrap_servers=['fooserver1:9092', 'fooserver2:9092'], client_id='foo', api_version=(2,2,1), security_protocol='SASL_SSL', sasl_mechanism='SCRAM-SHA-512', sasl_plain_username='myusername', sasl_plain_password='password123')

然而，我在连接时遇到以下错误：

<BrokerConnection node_id=bootstrap-0 host=fooserver1:9092 <authenticating> [IPv4 ('my.ip.ad.dress', 9092)]>: Error receiving reply from server
Traceback (most recent call last):    
File "/opt/python/kafka/conn.py", line 692, in _try_authenticate_scram(data_len,) = struct.unpack('>i', self._recv_bytes_blocking(4))
File "/opt/python/kafka/conn.py", line 616, in _recv_bytes_blocking raise ConnectionError('Connection reset during recv')
ConnectionError: Connection reset during recv

我已确保打开适当的端口以建立连接。我需要帮助来解决这个错误。

Answer 1

如果输入的用户名/密码组合不正确，可能会出现此错误。

您可以尝试验证配置Kafka集群时使用的用户名/密码是否与您在Kafka-python中使用的相同。