Function dataflow::source::kafka::get_kafka_partitions [−][src]
fn get_kafka_partitions(
consumer: &BaseConsumer<GlueConsumerContext>,
topic: &str,
timeout: Duration
) -> Result<Vec<i32>, Error>
Expand description
Return the list of partition ids associated with a specific topic