diff --git a/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py b/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py index ab149fc89cd37..8ab46c94ee7fc 100644 --- a/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py +++ b/kafka_consumer/datadog_checks/kafka_consumer/legacy_0_10_2.py @@ -103,7 +103,7 @@ def check(self, instance): self.log.debug( 'Identified api_version: %s, kafka_consumer_offsets: %s, zk_connection_string: %s.' ' Skipping consumer offset collection', - str(self._kafka_client.config.get('api_version') >= (0, 8, 2)), + str(self._kafka_client.config.get('api_version')), str(instance.get('kafka_consumer_offsets')), str(self._zk_hosts_ports), )