// Connect to Kafka Controller and query server for topic
Connect to Kafka Controller and query server for topic
Connect to Kafka Controller and query server for topic
pub async fn describe_kf_topics<O>(
    mut client: KfClient<String>,
    topics: Vec<String>,
    output_type: OutputType,
    out: std::sync::Arc<O>,
) -> Result<(), CliError>
where
    O: Terminal,
{
    let topic_args = if topics.len() > 0 { Some(topics) } else { None };
    // query none for empty topic_names array
    let topics = client.topic_metadata(topic_args).await?;
    let wrapper_topics: Vec<KfTopicMetadata> = topics
        .into_iter()
        .map(|t| KfTopicMetadata::new(t))
        .collect();
    out.describe_objects(&wrapper_topics, output_type)
}
pub async fn describe_kf_topics < O > ( mut client : KfClient < String > , topics : Vec < String > , output_type : OutputType , out : std :: sync :: Arc < O > , ) -> Result < ( ) , CliError > where O : Terminal , { let topic_args = if topics . len ( ) > 0 { Some ( topics ) } else { None } ; // query none for empty topic_names array let topics = client . topic_metadata ( topic_args ) . await ? ; let wrapper_topics : Vec < KfTopicMetadata > = topics . into_iter ( ) . map ( | t | KfTopicMetadata :: new ( t ) ) . collect ( ) ; out . describe_objects ( & wrapper_topics , output_type ) }
Connect to Kafka Controller and query server for topic
Connect to Kafka Controller and query server for topic
client
KfClient<String>
topics
Vec<String>
output_type
OutputType
out
std::sync::Arc<O>