fix

DataDog · Oct 6, 2020 · 6cf14fa · 6cf14fa
1 parent 0c3176f
commit 6cf14fa
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/kafka_consumer/tests/test_kafka_consumer.py b/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):