diff options
| -rw-r--r-- | kafka/client.py | 3 | ||||
| -rw-r--r-- | kafka/conn.py | 3 | ||||
| -rw-r--r-- | kafka/consumer/base.py | 3 | ||||
| -rw-r--r-- | kafka/consumer/multiprocess.py | 4 | ||||
| -rw-r--r-- | kafka/consumer/simple.py | 4 | ||||
| -rw-r--r-- | kafka/producer/base.py | 2 | ||||
| -rw-r--r-- | kafka/producer/keyed.py | 2 | ||||
| -rw-r--r-- | kafka/producer/simple.py | 2 | ||||
| -rw-r--r-- | kafka/protocol.py | 3 |
9 files changed, 17 insertions, 9 deletions
diff --git a/kafka/client.py b/kafka/client.py index 6ef9d83..7ea09d7 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -16,7 +16,8 @@ from kafka.conn import collect_hosts, KafkaConnection, DEFAULT_SOCKET_TIMEOUT_SE from kafka.protocol import KafkaProtocol from kafka.util import kafka_bytestring -log = logging.getLogger("kafka") + +log = logging.getLogger(__name__) class KafkaClient(object): diff --git a/kafka/conn.py b/kafka/conn.py index ea55481..7a49d8c 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -9,7 +9,8 @@ import six from kafka.common import ConnectionError -log = logging.getLogger("kafka") + +log = logging.getLogger(__name__) DEFAULT_SOCKET_TIMEOUT_SECONDS = 120 DEFAULT_KAFKA_PORT = 9092 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): """ diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 97565c3..5cbc521 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -25,7 +25,7 @@ from kafka.common import ( from kafka.protocol import CODEC_NONE, ALL_CODECS, create_message_set from kafka.util import kafka_bytestring -log = logging.getLogger("kafka") +log = logging.getLogger('kafka.producer') BATCH_SEND_DEFAULT_INTERVAL = 20 BATCH_SEND_MSG_COUNT = 20 diff --git a/kafka/producer/keyed.py b/kafka/producer/keyed.py index 5252976..6bb2285 100644 --- a/kafka/producer/keyed.py +++ b/kafka/producer/keyed.py @@ -11,7 +11,7 @@ from .base import ( ASYNC_RETRY_LIMIT, ASYNC_RETRY_BACKOFF_MS, ASYNC_RETRY_ON_TIMEOUTS ) -log = logging.getLogger("kafka") +log = logging.getLogger(__name__) class KeyedProducer(Producer): diff --git a/kafka/producer/simple.py b/kafka/producer/simple.py index ded6eb6..78cc21c 100644 --- a/kafka/producer/simple.py +++ b/kafka/producer/simple.py @@ -14,7 +14,7 @@ from .base import ( ASYNC_RETRY_LIMIT, ASYNC_RETRY_BACKOFF_MS, ASYNC_RETRY_ON_TIMEOUTS ) -log = logging.getLogger("kafka") +log = logging.getLogger(__name__) class SimpleProducer(Producer): diff --git a/kafka/protocol.py b/kafka/protocol.py index b34a95d..f12e6a3 100644 --- a/kafka/protocol.py +++ b/kafka/protocol.py @@ -21,7 +21,8 @@ from kafka.util import ( write_short_string, write_int_string, group_by_topic_and_partition ) -log = logging.getLogger("kafka") + +log = logging.getLogger(__name__) ATTRIBUTE_CODEC_MASK = 0x03 CODEC_NONE = 0x00 |