summaryrefslogtreecommitdiff
path: root/kafka/coordinator/protocol.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/coordinator/protocol.py')
-rw-r--r--kafka/coordinator/protocol.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/protocol.py b/kafka/coordinator/protocol.py
index 9e37397..56a3901 100644
--- a/kafka/coordinator/protocol.py
+++ b/kafka/coordinator/protocol.py
@@ -1,8 +1,8 @@
from __future__ import absolute_import
-from kafka.common import TopicPartition
from kafka.protocol.struct import Struct
from kafka.protocol.types import Array, Bytes, Int16, Int32, Schema, String
+from kafka.structs import TopicPartition
class ConsumerProtocolMemberMetadata(Struct):