diff --git a/kafka/sasl/scram.py b/kafka/sasl/scram.py index 4f3e60126..7188081eb 100644 --- a/kafka/sasl/scram.py +++ b/kafka/sasl/scram.py @@ -5,7 +5,7 @@ from kafka.protocol.types import Int32 from kafka.scram import ScramClient -log = logging.getLogger() +log = logging.getLogger(__name__) def validate_config(conn):