rlink-connector-kafka-0.6.6
- rlink-connector-kafka 0.6.6
- Permalink
- Docs.rs crate page
- MIT/Apache-2.0
- Links
- Repository
- crates.io
- Source
- Owners
- rlink-rs
- Dependencies
- anyhow ^1.0 normal
  
  futures ^0.3 normal
  
  log ^0.4 normal
  
  rdkafka ^0.25 normal
  
  rlink ^0.6 normal
  
  rlink-derive ^0.3 normal
  
  serbuffer ^1.3 normal
  
  serde ^1.0 normal
  
  serde_derive ^1.0 normal
  
  serde_json ^1.0 normal
  
  tokio ^1 dev
  
  serbuffer-gen ^1.3 build
- Versions
- 2.63% of the crate is documented
Platform
- x86_64-unknown-linux-gnu
Feature flags

Rust

rlink_connector_kafka0.6.6

All Items

Crate Items

Re-exports
Modules
Constants
Functions

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