Fix skipped integration tests if KAFKA_VERSION unset (dpkp#1453)

test/test_producer_integration.py

@@ -19,6 +19,7 @@
 from test.fixtures import ZookeeperFixture, KafkaFixture
 from test.testutil import KafkaIntegrationTestCase, kafka_versions, current_offset
 
+
 # TODO: This duplicates a TestKafkaProducerIntegration method temporarily
 # while the migration to pytest is in progress
 def assert_produce_request(client, topic, messages, initial_offset, message_ct,
@@ -34,13 +35,15 @@ def assert_produce_request(client, topic, messages, initial_offset, message_ct,
 
     assert current_offset(client, topic, partition) == initial_offset + message_ct
 
+
 def assert_produce_response(resp, initial_offset):
     """Verify that a produce response is well-formed
     """
     assert len(resp) == 1
     assert resp[0].error == 0
     assert resp[0].offset == initial_offset
 
+
 @pytest.mark.skipif(not version(), reason="No KAFKA_VERSION set")
 def test_produce_many_simple(simple_client, topic):
     """Test multiple produces using the SimpleClient