CommittableBytesMessage

constructor(inner: BytesMessage, coAcknowledge: suspend () -> Unit)