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 |