diff --git a/faststream/confluent/publisher/producer.py b/faststream/confluent/publisher/producer.py
index 97ebc3bc53..32facff148 100644
--- a/faststream/confluent/publisher/producer.py
+++ b/faststream/confluent/publisher/producer.py
@@ -45,7 +45,7 @@ async def disconnect(self) -> None:
     def __bool__(self) -> bool:
         return bool(self._producer)
 
-    async def ping(self, timeout: float) -> None:
+    async def ping(self, timeout: float) -> bool:
         return await self._producer.ping(timeout=timeout)
 
     @override
@@ -71,7 +71,8 @@ async def publish(  # type: ignore[override]
             no_confirm=cmd.no_confirm,
         )
 
-    async def publish_batch(
+    @override
+    async def publish_batch(  # type: ignore[override]
         self,
         cmd: "KafkaPublishCommand",
     ) -> None:
@@ -106,7 +107,7 @@ async def publish_batch(
         )
 
     @override
-    async def request(
+    async def request(  # type: ignore[override]
         self,
         cmd: "KafkaPublishCommand",
     ) -> Any: