summaryrefslogtreecommitdiff
path: root/kafka/consumer/simple.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/consumer/simple.py')
-rw-r--r--kafka/consumer/simple.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py
index ae00dab..2c2f820 100644
--- a/kafka/consumer/simple.py
+++ b/kafka/consumer/simple.py
@@ -34,7 +34,9 @@ from .base import (
NO_MESSAGES_WAIT_TIME_SECONDS
)
-log = logging.getLogger("kafka")
+
+log = logging.getLogger(__name__)
+
class FetchContext(object):
"""