Function rlink_connector_kafka::build_kafka_record[][src]

pub fn build_kafka_record(
    timestamp: i64,
    key: &[u8],
    payload: &[u8],
    topic: &str,
    partition: i32,
    offset: i64
) -> Result<Record, Error>