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>