pipekafka
| Crates.io | pipekafka |
| lib.rs | pipekafka |
| version | 0.2.3 |
| created_at | 2021-08-04 03:52:48.970336+00 |
| updated_at | 2021-12-26 00:22:05.002796+00 |
| description | A pipebase plugin using rdkafka |
| homepage | https://github.com/pipebase/pipebase |
| repository | https://github.com/pipebase/pipebase |
| max_upload_size | |
| id | 431330 |
| size | 14,070 |
Li Yu (51yu)
documentation
https://docs.rs/pipekafka/
README
A pipebase plugin using rust-rdkafka
Pipe Configs
| type | example |
|---|---|
KafkaConsumerConfig |
kafka_consumer |
KafkaPartitionedProducerConfig |
TBD |
KafkaProducerConfig |
kafka_producer |