Crate rlink_connector_kafka

Re-exports

pub use sink::output_format::KafkaOutputFormat;

pub use source::input_format::KafkaInputFormat;

Modules

buffer_gen

sink

source

Constants

BOOTSTRAP_SERVERS

BUFFER_SIZE

GROUP_ID

INPUT_FORMAT_FN_NAME_DEFAULT

KAFKA

OFFSET

OFFSET_BEGIN

OFFSET_END

OFFSET_TYPE

OUTPUT_FORMAT_FN_NAME_DEFAULT

SINK_CHANNEL_SIZE

SOURCE_CHANNEL_SIZE

TOPICS

Functions

build_kafka_record