classReplicationStateInfo(TypedDict,closed=True):code:NotRequired["capo_kafka.types.__string.__string"]"""Code that describes the current state of the replicator."""message:NotRequired["capo_kafka.types.__string.__string"]"""Message that describes the state of the replicator."""