Method init

examples/kafka_processor_complex.rs:75–75

(&mut self)

impl Producer<ProcKafkaMessage> for Prod {

    async fn init(&mut self) {}

    async fn terminate(&mut self) {}