[−][src]Struct eventio::kafka::Input
Event reader for Apache Kafka.
Methods
impl Input[src]
pub fn new(
data_channel: Sender<Event>,
ack_channel: Receiver<EntryLocation>,
hosts: Vec<String>,
group: String,
client_id: String,
topic: String,
fetch_limit: usize
) -> Result<Self, Error>[src]
data_channel: Sender<Event>,
ack_channel: Receiver<EntryLocation>,
hosts: Vec<String>,
group: String,
client_id: String,
topic: String,
fetch_limit: usize
) -> Result<Self, Error>
Creates Input that fetches at most fetch_limit entries from the
given Kafka topic.
Trait Implementations
Auto Trait Implementations
impl Send for Input
impl Sync for Input
impl Unpin for Input
impl UnwindSafe for Input
impl RefUnwindSafe for Input
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> From<T> for T[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,