Struct dataflow::source::kafka::PartitionConsumer [−][src]
struct PartitionConsumer {
pid: i32,
partition_queue: PartitionQueue<GlueConsumerContext>,
}
Expand description
Wrapper around a partition containing the underlying consumer
Fields
pid: i32
the partition id with which this consumer is associated
partition_queue: PartitionQueue<GlueConsumerContext>
The underlying Kafka partition queue
Implementations
Creates a new partition consumer from underlying Kafka consumer
fn get_next_message(
&mut self
) -> Result<Option<SourceMessage<Option<Vec<u8>>, Option<Vec<u8>>>>, KafkaError>
fn get_next_message(
&mut self
) -> Result<Option<SourceMessage<Option<Vec<u8>>, Option<Vec<u8>>>>, KafkaError>
Returns the next message to process for this partition (if any).
Auto Trait Implementations
impl !RefUnwindSafe for PartitionConsumer
impl Send for PartitionConsumer
impl Sync for PartitionConsumer
impl Unpin for PartitionConsumer
impl !UnwindSafe for PartitionConsumer
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