Struct coord::timestamp::RtKafkaConnector [−][src]
struct RtKafkaConnector {
coordination_state: Arc<TimestampingState>,
id: GlobalId,
topic: String,
}
Expand description
Data consumer for Kafka source with RT consistency
Fields
coordination_state: Arc<TimestampingState>
id: GlobalId
topic: String
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for RtKafkaConnector
impl Send for RtKafkaConnector
impl Sync for RtKafkaConnector
impl Unpin for RtKafkaConnector
impl !UnwindSafe for RtKafkaConnector
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more