diff --git a/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py b/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py
index 73b06916906db..a94a722c494f6 100644
--- a/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py
+++ b/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py
@@ -127,10 +127,7 @@ def _create_kafka_admin_client(self, api_version):
             bootstrap_servers=kafka_connect_str,
             client_id='dd-agent',
             request_timeout_ms=self.init_config.get('kafka_timeout', DEFAULT_KAFKA_TIMEOUT) * 1000,
-            # There is a bug with kafka-python where pinning api_version for KafkaAdminClient raises an
-            # `IncompatibleBrokerVersion`. Change to `api_version=api_version` once fixed upstream.
-            # See linked issues in PR: https://github.com/dpkp/kafka-python/pull/1953
-            api_version=None,
+            api_version=api_version,
             # While we check for SASL/SSL params, if not present they will default to the kafka-python values for
             # plaintext connections
             security_protocol=self.instance.get('security_protocol', 'PLAINTEXT'),