Crate rlink_connector_kafka[−][src]
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 |