fix

Author: ofek

kafka_consumer/tests/test_kafka_consumer.py

@@ -1,6 +1,8 @@
 # (C) Datadog, Inc. 2018-present
 # All rights reserved
 # Licensed under Simplified BSD License (see LICENSE)
+import os
+
 import pytest
 
 from datadog_checks.kafka_consumer import KafkaCheck
@@ -97,6 +99,7 @@ def test_no_partitions(aggregator, kafka_instance):
     assert_check_kafka(aggregator, {'my_consumer': {'marvel': [0]}})
 
 
+@pytest.mark.skipif(os.environ.get('KAFKA_VERSION', '').startswith('0.9'), reason='Old Kafka version')
 @pytest.mark.integration
 @pytest.mark.usefixtures('dd_environment')
 def test_version_metadata(datadog_agent, kafka_instance):