diff --git a/taskiq/brokers/zmq_broker.py b/taskiq/brokers/zmq_broker.py
index 88711fa..84af799 100644
--- a/taskiq/brokers/zmq_broker.py
+++ b/taskiq/brokers/zmq_broker.py
@@ -77,7 +77,7 @@ async def kick(self, message: BrokerMessage) -> None:
             ]
             for idx in range(math.ceil(len(message.message) / part_len))
         ]
-        with self.socket.connect(self.sub_host) as sock:
+        with self.socket.connect(self.pub_host) as sock:
             await sock.send_multipart(parts)
 
     async def listen(self) -> AsyncGenerator[bytes, None]: