MCPcopy Create free account
hub / github.com/Rustixir/tokio_sky / kafka_processor_complex.rs

File kafka_processor_complex.rs

examples/kafka_processor_complex.rs:None–None  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1use tokio_sky::builtin::kafka_processor::KafkaProcessor;
2
3
4#[tokio::main]

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected