AsyncConfluentFastProducer

def connect(
    self,
    producer: "AsyncConfluentProducer",
    serializer: Optional["SerializerProto"],
    codec: Optional["CodecProto"] = None,
) -> None: ...

async def disconnect(self) -> None:  # noqa: PLR6301
    return None

async def flush(self) -> None:  # noqa: PLR6301
    return None

@abstractmethod
async def ping(self, timeout: float) -> bool:
    return False

@override
@abstractmethod
async def publish(
    self,
    cmd: "KafkaPublishCommand",
) -> "asyncio.Future[Message | None] | Message | None": ...

@override
@abstractmethod
async def publish_batch(self, cmd: "KafkaPublishCommand") -> None: ...

@override
async def request(self, cmd: "KafkaPublishCommand") -> Any:
    msg = "Kafka doesn't support `request` method without test client."
    raise FeatureNotSupportedException(msg)