diff options
Diffstat (limited to 'kafka/protocol.py')
| -rw-r--r-- | kafka/protocol.py | 3 |
1 files changed, 2 insertions, 1 deletions
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 |