Use test.fixtures.version not test.conftest.version to avoid warnings (#1731)

Author: dpkp

test/test_consumer_group.py

@@ -11,8 +11,7 @@
 from kafka.coordinator.base import MemberState, Generation
 from kafka.structs import TopicPartition
 
-from test.conftest import version
-from test.fixtures import random_string
+from test.fixtures import random_string, version
 
 
 def get_connect_str(kafka_broker):

test/test_consumer_integration.py

@@ -23,8 +23,7 @@
     ProduceRequestPayload, TopicPartition, OffsetAndTimestamp
 )
 
-from test.conftest import version
-from test.fixtures import ZookeeperFixture, KafkaFixture, random_string
+from test.fixtures import ZookeeperFixture, KafkaFixture, random_string, version
 from test.testutil import KafkaIntegrationTestCase, kafka_versions, Timer
 
 

test/test_producer.py

@@ -7,8 +7,7 @@
 
 from kafka import KafkaConsumer, KafkaProducer, TopicPartition
 from kafka.producer.buffer import SimpleBufferPool
-from test.conftest import version
-from test.fixtures import random_string
+from test.fixtures import random_string, version
 
 
 def test_buffer_pool():

test/test_producer_integration.py

@@ -15,8 +15,7 @@
 from kafka.producer.base import Producer
 from kafka.structs import FetchRequestPayload, ProduceRequestPayload
 
-from test.conftest import version
-from test.fixtures import ZookeeperFixture, KafkaFixture
+from test.fixtures import ZookeeperFixture, KafkaFixture, version
 from test.testutil import KafkaIntegrationTestCase, kafka_versions, current_offset