diff --git a/requirements.txt b/requirements.txt
index 02846f0..146763c 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -13,6 +13,7 @@ wheel==0.37.1
 autoflake==1.4
 black==22.6.0
 coverage==6.4.4
+importlib-metadata==4.13.0
 flake8==3.9.2
 flake8-bugbear==22.7.1
 flake8-pie==0.16.0
diff --git a/tests/test_broadcast.py b/tests/test_broadcast.py
index e3313bc..908a8e8 100644
--- a/tests/test_broadcast.py
+++ b/tests/test_broadcast.py
@@ -35,11 +35,11 @@ async def test_postgres():
             assert event.message == "hello"
 
 
-@pytest.mark.skip("Deadlock on `next_published`")
 @pytest.mark.asyncio
 async def test_kafka():
     async with Broadcast("kafka://localhost:9092") as broadcast:
         async with broadcast.subscribe("chatroom") as subscriber:
+            await broadcast._backend._consumer._client.force_metadata_update()  # type: ignore
             await broadcast.publish("chatroom", "hello")
             event = await subscriber.get()
             assert event.channel == "chatroom"