Crate kafka_common 

Kafka common components for kinetic sources and sinks.

Re-exports

pub use client::create_consumer;

pub use client::create_producer;

pub use config::KafkaClientConfig;

pub use config::KafkaConsumerConfig;

pub use config::KafkaProducerConfig;

Modules

client

Helper functions to create rdkafka clients from configuration.

config

Configuration structs for Kafka clients.