1 files changed, 1 insertions, 2 deletions
diff --git a/example.py b/example.py
index 286bfdb..ced32dd 100644
--- a/example.py
+++ b/example.py
@@ -1,6 +1,6 @@
 import logging
 
-from kafka import KafkaClient, FetchRequest, ProduceRequest
+from kafka.client import KafkaClient, FetchRequest, ProduceRequest
 
 def produce_example(kafka):
     message = kafka.create_message("testing")
@@ -26,7 +26,6 @@ def main():
     consume_example(kafka)
     kafka.close()
 
-
 if __name__ == "__main__":
     logging.basicConfig(level=logging.DEBUG)
     main()