Crate rlink_connector_kafka

Re-exports

pub use sink::output_format::KafkaOutputFormat;

pub use source::input_format::KafkaInputFormat;

Modules

sink

source

Structs

KafkaRecord

Constants

BOOTSTRAP_SERVERS

GROUP_ID

SINK_CHANNEL_SIZE

SOURCE_CHANNEL_SIZE

TOPICS

Statics

KAFKA_DATA_TYPES

Functions

build_kafka_record

create_input_format

create_output_format

field