avantis-utils 0.7.2

Swiss army knife utilities for all kind of Avantis rust projects
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use bytes::Bytes;
use rdkafka::producer::FutureRecord;
use serde::Deserialize;
use std::ops::Deref;

pub mod consumer;
pub mod producer;

#[derive(Clone, Debug, PartialEq, Eq, Deserialize)]
pub struct KafkaConfig {
    pub brokers_csv: String,
    pub flush_duration_millis: u64,
    pub poll_duration_millis: u64,
    pub security_protocol: Option<String>,
}

pub struct ProtobufKafkaRecord<'a> {
    pub topic: &'a str,
    pub message: ProtobufKafkaMessage,
}

pub struct ProtobufKafkaMessage {
    pub key: String,
    pub value: Bytes,
}

impl<'a> From<&'a ProtobufKafkaRecord<'a>> for FutureRecord<'a, String, [u8]> {
    fn from(record: &'a ProtobufKafkaRecord<'a>) -> FutureRecord<'a, String, [u8]> {
        FutureRecord::to(record.topic)
            .key(&record.message.key)
            .payload(record.message.value.deref())
    }
}