Struct dataflow_types::sources::KafkaSourceConnector [−][src]
pub struct KafkaSourceConnector {
pub addrs: KafkaAddrs,
pub topic: String,
pub config_options: BTreeMap<String, String>,
pub start_offsets: HashMap<i32, i64>,
pub group_id_prefix: Option<String>,
pub cluster_id: Uuid,
pub include_timestamp: Option<IncludedColumnPos>,
pub include_partition: Option<IncludedColumnPos>,
pub include_topic: Option<IncludedColumnPos>,
pub include_offset: Option<IncludedColumnPos>,
}
Fields
addrs: KafkaAddrs
topic: String
config_options: BTreeMap<String, String>
start_offsets: HashMap<i32, i64>
group_id_prefix: Option<String>
cluster_id: Uuid
include_timestamp: Option<IncludedColumnPos>
If present, include the timestamp as an output column of the source with the given name
include_partition: Option<IncludedColumnPos>
If present, include the partition as an output column of the source with the given name.
include_topic: Option<IncludedColumnPos>
If present, include the topic as an output column of the source with the given name.
include_offset: Option<IncludedColumnPos>
If present, include the offset as an output column of the source with the given name.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for KafkaSourceConnector
impl Send for KafkaSourceConnector
impl Sync for KafkaSourceConnector
impl Unpin for KafkaSourceConnector
impl UnwindSafe for KafkaSourceConnector
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
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