rdcm / web-api Goto Github PK

        let record = FutureRecord::to(&self.topic).key("").payload(&buffer);

        self.producer
            .send(record, Duration::from_secs(0))
            .await
            .ok()?;

        Some(())

   async fn produce(&self, message: &T) -> Option<()> {
        let json = serde_json::to_string(&message).ok()?;
        let record: FutureRecord<String, String> = FutureRecord::to(&self.topic).payload(&json);

        self.producer
            .send(record, Duration::from_secs(0))
            .await
            .ok()?;

        Some(())
    }