diff --git a/kafka_consumer/tests/test_kafka_consumer.py b/kafka_consumer/tests/test_kafka_consumer.py index 8e16a6f38191e..701e1d61c9844 100644 --- 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):