andrejohnson-expedia

SASL connect fails with RuntimeError: await wasn't used with future

5

robinhood-aiokafka version 1.1.3 Connecting to Kafka using SASL fails with 'RuntimeError: await wasn't used with future' in aiokafka/conn.py, AIOKafkaConnection._do_sasl_handshake(): res = await authenticator.step(auth_bytes) Fix is missing await in aiokafka/conn.py: class...