FakeAioKafkaFastProducer

async def connect(
    self,
    producer: "AIOKafkaProducer",
    serializer: Optional["SerializerProto"],
    codec: Optional["CodecProto"] = None,
) -> None:
    raise NotImplementedError

async def disconnect(self) -> None:
    raise NotImplementedError

async def flush(self) -> None:
    raise NotImplementedError

async def publish(
    self,
    cmd: "KafkaPublishCommand",
) -> Union["asyncio.Future[RecordMetadata]", "RecordMetadata"]:
    raise NotImplementedError

async def publish_batch(
    self,
    cmd: "KafkaPublishCommand",
) -> Union["asyncio.Future[RecordMetadata]", "RecordMetadata"]:
    raise NotImplementedError

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