Update imports from kafka.common -> kafka.errors / kafka.structs

1 files changed, 4 insertions, 4 deletions

diff --git a/test/test_client_integration.py b/test/test_client_integration.py
index c5d3b58..742572d 100644
--- a/test/test_client_integration.py
+++ b/test/test_client_integration.py
@@ -1,10 +1,10 @@
 import os
 
-from kafka.common import (
-    FetchRequestPayload, OffsetCommitRequestPayload, OffsetFetchRequestPayload,
-    KafkaTimeoutError, ProduceRequestPayload
-)
+from kafka.errors import KafkaTimeoutError
 from kafka.protocol import create_message
+from kafka.structs import (
+    FetchRequestPayload, OffsetCommitRequestPayload, OffsetFetchRequestPayload,
+    ProduceRequestPayload)
 
 from test.fixtures import ZookeeperFixture, KafkaFixture
 from test.testutil import KafkaIntegrationTestCase, kafka_versions