// 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_sc_topics<O>(
    mut client: ScClient<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 inner: Vec<ScTopicMetadata> = topics.into_iter().map(|t| ScTopicMetadata::new(t)).collect();
    out.describe_objects(&inner,output_type)    
}
pub async fn describe_sc_topics < O > ( mut client : ScClient < 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 inner : Vec < ScTopicMetadata > = topics . into_iter ( ) . map ( | t | ScTopicMetadata :: new ( t ) ) . collect ( ) ; out . describe_objects ( & inner , output_type ) }
Connect to Kafka Controller and query server for topic
Connect to Kafka Controller and query server for topic
client
ScClient<String>
topics
Vec<String>
output_type
OutputType
out
std::sync::Arc<O>