Struct sea_streamer_kafka::KafkaStreamer

pub struct KafkaStreamer { /* private fields */ }

Trait Implementations

impl Clone for KafkaStreamer

fn clone(&self) -> KafkaStreamer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaStreamer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Streamer for KafkaStreamer

async fn disconnect(self) -> KafkaResult<()>

It will flush all producers

async fn create_consumer( &self, streams: &[StreamKey], options: Self::ConsumerOptions ) -> KafkaResult<Self::Consumer>

If ConsumerMode is RealTime, auto commit will be disabled and it always stream from latest. group_id must not be set.

If ConsumerMode is Resumable, it will use a group id unique to this host: on a physical machine, it will use the mac address. Inside a docker container, it will use the container id. So when the process restarts, it will resume from last committed offset. group_id must not be set.

If ConsumerMode is LoadBalanced, shards will be divided-and-assigned by the broker to consumers sharing the same group_id. group_id must already be set.

If you need to override the HOST ID, you can set the ENV var HOST_ID.

type Error = KafkaError

type Producer = KafkaProducer

type Consumer = KafkaConsumer

type ConnectOptions = KafkaConnectOptions

type ConsumerOptions = KafkaConsumerOptions

type ProducerOptions = KafkaProducerOptions

async fn connect( uri: StreamerUri, options: Self::ConnectOptions ) -> KafkaResult<Self>

Establish a connection to the streaming server.

async fn create_generic_producer( &self, options: Self::ProducerOptions ) -> KafkaResult<Self::Producer>

Create a producer that can stream to any stream key.

fn create_producer( &self, stream: StreamKey, options: Self::ProducerOptions ) -> impl Future<Output = Result<Self::Producer, StreamErr<Self::Error>>> + Send

Create a producer that streams to the specified stream.