risingwave_connector::sink::kafka

Type Alias KafkaSinkDeliveryFuture

source
pub type KafkaSinkDeliveryFuture = impl TryFuture<Ok = (), Error = SinkError> + Unpin + 'static;