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