Use separate module loggers instead of a single 'kafka' logger

3 files changed, 8 insertions, 3 deletions

diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py
index f53217f..6365cfa 100644
--- a/kafka/consumer/base.py
+++ b/kafka/consumer/base.py
@@ -13,7 +13,8 @@ from kafka.common import (
 
 from kafka.util import kafka_bytestring, ReentrantTimer
 
-log = logging.getLogger("kafka")
+
+log = logging.getLogger('kafka.consumer')
 
 AUTO_COMMIT_MSG_COUNT = 100
 AUTO_COMMIT_INTERVAL = 5000
diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py
index cfe0ef6..2ca76b6 100644
--- a/kafka/consumer/multiprocess.py
+++ b/kafka/consumer/multiprocess.py
@@ -18,9 +18,11 @@ from .base import (
 )
 from .simple import Consumer, SimpleConsumer
 
+
+log = logging.getLogger(__name__)
+
 Events = namedtuple("Events", ["start", "pause", "exit"])
 
-log = logging.getLogger("kafka")
 
 def _mp_consume(client, group, topic, queue, size, events, **consumer_options):
     """
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):
     """