Struct mz_test_util::kafka::kafka_client::KafkaClient

pub struct KafkaClient {
    producer: FutureProducer<MzClientContext>,
    kafka_url: String,
}

Fields

producer: FutureProducer<MzClientContext>

kafka_url: String

Implementations

impl KafkaClient

pub fn new( kafka_url: &str, group_id: &str, configs: &[(&str, &str)], ) -> Result<KafkaClient, Error>

pub async fn create_topic( &self, topic_name: &str, partitions: i32, replication: i32, configs: &[(&str, &str)], timeout: Option<Duration>, ) -> Result<(), Error>

pub fn send( &self, topic_name: &str, message: &[u8], ) -> Result<DeliveryFuture, KafkaError>

pub fn send_key_value( &self, topic_name: &str, key: &[u8], message: Option<Vec<u8>>, ) -> Result<DeliveryFuture, KafkaError>