diff --git a/homeassistant/components/apache_kafka/__init__.py b/homeassistant/components/apache_kafka/__init__.py
index 1b293bd2c04..38a70b450ab 100644
--- a/homeassistant/components/apache_kafka/__init__.py
+++ b/homeassistant/components/apache_kafka/__init__.py
@@ -102,7 +102,6 @@ class KafkaManager:
         self._hass = hass
         ssl_context = ssl_util.client_context()
         self._producer = AIOKafkaProducer(
-            loop=hass.loop,
             bootstrap_servers=f"{ip_address}:{port}",
             compression_type="gzip",
             security_protocol=security_protocol,
diff --git a/homeassistant/components/apache_kafka/manifest.json b/homeassistant/components/apache_kafka/manifest.json
index 3b290146a09..3fa1f70c57b 100644
--- a/homeassistant/components/apache_kafka/manifest.json
+++ b/homeassistant/components/apache_kafka/manifest.json
@@ -2,7 +2,7 @@
   "domain": "apache_kafka",
   "name": "Apache Kafka",
   "documentation": "https://www.home-assistant.io/integrations/apache_kafka",
-  "requirements": ["aiokafka==0.6.0"],
+  "requirements": ["aiokafka==0.7.2"],
   "codeowners": ["@bachya"],
   "iot_class": "local_push",
   "loggers": ["aiokafka", "kafka_python"]
diff --git a/requirements_all.txt b/requirements_all.txt
index 8844b7e2464..ea5bd8cca1e 100644
--- a/requirements_all.txt
+++ b/requirements_all.txt
@@ -181,7 +181,7 @@ aiohue==4.4.2
 aioimaplib==1.0.0
 
 # homeassistant.components.apache_kafka
-aiokafka==0.6.0
+aiokafka==0.7.2
 
 # homeassistant.components.kef
 aiokef==0.2.16
diff --git a/requirements_test_all.txt b/requirements_test_all.txt
index 737550785d9..3cbc10480bb 100644
--- a/requirements_test_all.txt
+++ b/requirements_test_all.txt
@@ -162,7 +162,7 @@ aiohttp_cors==0.7.0
 aiohue==4.4.2
 
 # homeassistant.components.apache_kafka
-aiokafka==0.6.0
+aiokafka==0.7.2
 
 # homeassistant.components.lookin
 aiolookin==0.1.1