async def METHOD_NAME(
    self,
    *,
    key: K = None,
    value: V = None,
    partition: Optional[int] = None,
    timestamp: Optional[float] = None,
    headers: HeadersArg = None,
    schema: Optional[_SchemaT] = None,
    key_serializer: CodecArg = None,
    value_serializer: CodecArg = None,
    callback: Optional[MessageSentCallback] = None,
    force: bool = False,
) -> Awaitable[RecordMetadata]:
    ...