Function sql::kafka_util::fetch_end_offset [−][src]
fn fetch_end_offset(
consumer: &BaseConsumer<KafkaErrCheckContext>,
topic: &str,
pid: i32
) -> Result<i64, Error>fn fetch_end_offset(
consumer: &BaseConsumer<KafkaErrCheckContext>,
topic: &str,
pid: i32
) -> Result<i64, Error>