summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index ac8bb3d..d042300 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -19,6 +19,7 @@ from kafka.protocol.api import RequestHeader
from kafka.protocol.admin import SaslHandShakeRequest
from kafka.protocol.commit import GroupCoordinatorResponse, OffsetFetchRequest
from kafka.protocol.metadata import MetadataRequest
+from kafka.protocol.fetch import FetchRequest
from kafka.protocol.types import Int32
from kafka.version import __version__