import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        Boolean requireTimelineMetrics = true; // Boolean | Whether to fetch timeline metrics
        String state = state_example; // String | State of the Client
        try {
            array[AggrConsumerMetrics] result = apiInstance.getAllConsumerGroupMetrics(duration, from, to, requireTimelineMetrics, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getAllConsumerGroupMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        Boolean requireTimelineMetrics = true; // Boolean | Whether to fetch timeline metrics
        String state = state_example; // String | State of the Client
        try {
            array[AggrConsumerMetrics] result = apiInstance.getAllConsumerGroupMetrics(duration, from, to, requireTimelineMetrics, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getAllConsumerGroupMetrics");
            e.printStackTrace();
        }
    }
}

String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)
Boolean *requireTimelineMetrics = true; // Whether to fetch timeline metrics (optional)
String *state = state_example; // State of the Client (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get all consumer group details.
[apiInstance getAllConsumerGroupMetricsWith:duration
    from:from
    to:to
    requireTimelineMetrics:requireTimelineMetrics
    state:state
              completionHandler: ^(array[AggrConsumerMetrics] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789, // {{Long}} End of the time period. Provide '-1' to fetch the latest value
  'requireTimelineMetrics': true, // {{Boolean}} Whether to fetch timeline metrics
  'state': state_example // {{String}} State of the Client
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getAllConsumerGroupMetrics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getAllConsumerGroupMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 
            var requireTimelineMetrics = true;  // Boolean | Whether to fetch timeline metrics (optional) 
            var state = state_example;  // String | State of the Client (optional) 

            try
            {
                // Get all consumer group details.
                array[AggrConsumerMetrics] result = apiInstance.getAllConsumerGroupMetrics(duration, from, to, requireTimelineMetrics, state);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getAllConsumerGroupMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
$requireTimelineMetrics = true; // Boolean | Whether to fetch timeline metrics
$state = state_example; // String | State of the Client

try {
    $result = $api_instance->getAllConsumerGroupMetrics($duration, $from, $to, $requireTimelineMetrics, $state);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getAllConsumerGroupMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value
my $requireTimelineMetrics = true; # Boolean | Whether to fetch timeline metrics
my $state = state_example; # String | State of the Client

eval { 
    my $result = $api_instance->getAllConsumerGroupMetrics(duration => $duration, from => $from, to => $to, requireTimelineMetrics => $requireTimelineMetrics, state => $state);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getAllConsumerGroupMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)
requireTimelineMetrics = true # Boolean | Whether to fetch timeline metrics (optional)
state = state_example # String | State of the Client (optional)

try: 
    # Get all consumer group details.
    api_response = api_instance.get_all_consumer_group_metrics(duration=duration, from=from, to=to, requireTimelineMetrics=requireTimelineMetrics, state=state)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getAllConsumerGroupMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        String state = state_example; // String | State of the Client
        try {
            array[AggrProducerMetrics] result = apiInstance.getAllProducerMetrics(duration, from, to, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getAllProducerMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        String state = state_example; // String | State of the Client
        try {
            array[AggrProducerMetrics] result = apiInstance.getAllProducerMetrics(duration, from, to, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getAllProducerMetrics");
            e.printStackTrace();
        }
    }
}

String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)
String *state = state_example; // State of the Client (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get producer metrics for all the alive producers
[apiInstance getAllProducerMetricsWith:duration
    from:from
    to:to
    state:state
              completionHandler: ^(array[AggrProducerMetrics] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789, // {{Long}} End of the time period. Provide '-1' to fetch the latest value
  'state': state_example // {{String}} State of the Client
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getAllProducerMetrics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getAllProducerMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 
            var state = state_example;  // String | State of the Client (optional) 

            try
            {
                // Get producer metrics for all the alive producers
                array[AggrProducerMetrics] result = apiInstance.getAllProducerMetrics(duration, from, to, state);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getAllProducerMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
$state = state_example; // String | State of the Client

try {
    $result = $api_instance->getAllProducerMetrics($duration, $from, $to, $state);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getAllProducerMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value
my $state = state_example; # String | State of the Client

eval { 
    my $result = $api_instance->getAllProducerMetrics(duration => $duration, from => $from, to => $to, state => $state);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getAllProducerMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)
state = state_example # String | State of the Client (optional)

try: 
    # Get producer metrics for all the alive producers
    api_response = api_instance.get_all_producer_metrics(duration=duration, from=from, to=to, state=state)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getAllProducerMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        Integer brokerId = 56; // Integer | Broker id
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            BrokerDetails result = apiInstance.getBrokerDetails(brokerId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getBrokerDetails");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        Integer brokerId = 56; // Integer | Broker id
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            BrokerDetails result = apiInstance.getBrokerDetails(brokerId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getBrokerDetails");
            e.printStackTrace();
        }
    }
}

Integer *brokerId = 56; // Broker id
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get broker details with metrics for a given brokerId
[apiInstance getBrokerDetailsWith:brokerId
    duration:duration
    from:from
    to:to
              completionHandler: ^(BrokerDetails output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var brokerId = 56; // {{Integer}} Broker id
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBrokerDetails(brokerId, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokerDetailsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var brokerId = 56;  // Integer | Broker id
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get broker details with metrics for a given brokerId
                BrokerDetails result = apiInstance.getBrokerDetails(brokerId, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getBrokerDetails: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$brokerId = 56; // Integer | Broker id
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getBrokerDetails($brokerId, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getBrokerDetails: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $brokerId = 56; # Integer | Broker id
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getBrokerDetails(brokerId => $brokerId, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getBrokerDetails: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
brokerId = 56 # Integer | Broker id
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get broker details with metrics for a given brokerId
    api_response = api_instance.get_broker_details(brokerId, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getBrokerDetails: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            ClusterWithBrokerMetrics result = apiInstance.getClusterWithBrokerMetrics(duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getClusterWithBrokerMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            ClusterWithBrokerMetrics result = apiInstance.getClusterWithBrokerMetrics(duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getClusterWithBrokerMetrics");
            e.printStackTrace();
        }
    }
}

String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get cluster with broker metrics
[apiInstance getClusterWithBrokerMetricsWith:duration
    from:from
    to:to
              completionHandler: ^(ClusterWithBrokerMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getClusterWithBrokerMetrics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getClusterWithBrokerMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get cluster with broker metrics
                ClusterWithBrokerMetrics result = apiInstance.getClusterWithBrokerMetrics(duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getClusterWithBrokerMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getClusterWithBrokerMetrics($duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getClusterWithBrokerMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getClusterWithBrokerMetrics(duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getClusterWithBrokerMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get cluster with broker metrics
    api_response = api_instance.get_cluster_with_broker_metrics(duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getClusterWithBrokerMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        String state = state_example; // String | State of the Client
        try {
            ClusterWithTopicMetrics result = apiInstance.getClusterWithTopicMetrics(duration, from, to, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getClusterWithTopicMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        String state = state_example; // String | State of the Client
        try {
            ClusterWithTopicMetrics result = apiInstance.getClusterWithTopicMetrics(duration, from, to, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getClusterWithTopicMetrics");
            e.printStackTrace();
        }
    }
}

String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)
String *state = state_example; // State of the Client (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get cluster with topic metrics
[apiInstance getClusterWithTopicMetricsWith:duration
    from:from
    to:to
    state:state
              completionHandler: ^(ClusterWithTopicMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789, // {{Long}} End of the time period. Provide '-1' to fetch the latest value
  'state': state_example // {{String}} State of the Client
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getClusterWithTopicMetrics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getClusterWithTopicMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 
            var state = state_example;  // String | State of the Client (optional) 

            try
            {
                // Get cluster with topic metrics
                ClusterWithTopicMetrics result = apiInstance.getClusterWithTopicMetrics(duration, from, to, state);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getClusterWithTopicMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
$state = state_example; // String | State of the Client

try {
    $result = $api_instance->getClusterWithTopicMetrics($duration, $from, $to, $state);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getClusterWithTopicMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value
my $state = state_example; # String | State of the Client

eval { 
    my $result = $api_instance->getClusterWithTopicMetrics(duration => $duration, from => $from, to => $to, state => $state);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getClusterWithTopicMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)
state = state_example # String | State of the Client (optional)

try: 
    # Get cluster with topic metrics
    api_response = api_instance.get_cluster_with_topic_metrics(duration=duration, from=from, to=to, state=state)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getClusterWithTopicMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String groupName = groupName_example; // String | Name of the consumer group
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        Boolean requireTimelineMetrics = true; // Boolean | Whether to fetch timeline metrics
        String state = state_example; // String | State of the Producer
        try {
            AggrConsumerMetrics result = apiInstance.getConsumerGroupMetrics(groupName, duration, from, to, requireTimelineMetrics, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getConsumerGroupMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String groupName = groupName_example; // String | Name of the consumer group
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        Boolean requireTimelineMetrics = true; // Boolean | Whether to fetch timeline metrics
        String state = state_example; // String | State of the Producer
        try {
            AggrConsumerMetrics result = apiInstance.getConsumerGroupMetrics(groupName, duration, from, to, requireTimelineMetrics, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getConsumerGroupMetrics");
            e.printStackTrace();
        }
    }
}

String *groupName = groupName_example; // Name of the consumer group
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)
Boolean *requireTimelineMetrics = true; // Whether to fetch timeline metrics (optional)
String *state = state_example; // State of the Producer (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get consumer group details for the given groupName.
[apiInstance getConsumerGroupMetricsWith:groupName
    duration:duration
    from:from
    to:to
    requireTimelineMetrics:requireTimelineMetrics
    state:state
              completionHandler: ^(AggrConsumerMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var groupName = groupName_example; // {{String}} Name of the consumer group
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789, // {{Long}} End of the time period. Provide '-1' to fetch the latest value
  'requireTimelineMetrics': true, // {{Boolean}} Whether to fetch timeline metrics
  'state': state_example // {{String}} State of the Producer
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getConsumerGroupMetrics(groupName, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getConsumerGroupMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var groupName = groupName_example;  // String | Name of the consumer group
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 
            var requireTimelineMetrics = true;  // Boolean | Whether to fetch timeline metrics (optional) 
            var state = state_example;  // String | State of the Producer (optional) 

            try
            {
                // Get consumer group details for the given groupName.
                AggrConsumerMetrics result = apiInstance.getConsumerGroupMetrics(groupName, duration, from, to, requireTimelineMetrics, state);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getConsumerGroupMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$groupName = groupName_example; // String | Name of the consumer group
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
$requireTimelineMetrics = true; // Boolean | Whether to fetch timeline metrics
$state = state_example; // String | State of the Producer

try {
    $result = $api_instance->getConsumerGroupMetrics($groupName, $duration, $from, $to, $requireTimelineMetrics, $state);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getConsumerGroupMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $groupName = groupName_example; # String | Name of the consumer group
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value
my $requireTimelineMetrics = true; # Boolean | Whether to fetch timeline metrics
my $state = state_example; # String | State of the Producer

eval { 
    my $result = $api_instance->getConsumerGroupMetrics(groupName => $groupName, duration => $duration, from => $from, to => $to, requireTimelineMetrics => $requireTimelineMetrics, state => $state);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getConsumerGroupMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
groupName = groupName_example # String | Name of the consumer group
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)
requireTimelineMetrics = true # Boolean | Whether to fetch timeline metrics (optional)
state = state_example # String | State of the Producer (optional)

try: 
    # Get consumer group details for the given groupName.
    api_response = api_instance.get_consumer_group_metrics(groupName, duration=duration, from=from, to=to, requireTimelineMetrics=requireTimelineMetrics, state=state)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getConsumerGroupMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String producerClientId = producerClientId_example; // String | Producer client identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            AggrProducerMetrics result = apiInstance.getProducerMetrics(producerClientId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getProducerMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String producerClientId = producerClientId_example; // String | Producer client identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            AggrProducerMetrics result = apiInstance.getProducerMetrics(producerClientId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getProducerMetrics");
            e.printStackTrace();
        }
    }
}

String *producerClientId = producerClientId_example; // Producer client identifier
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get producer metrics for the given producerClientId
[apiInstance getProducerMetricsWith:producerClientId
    duration:duration
    from:from
    to:to
              completionHandler: ^(AggrProducerMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var producerClientId = producerClientId_example; // {{String}} Producer client identifier
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getProducerMetrics(producerClientId, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getProducerMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var producerClientId = producerClientId_example;  // String | Producer client identifier
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get producer metrics for the given producerClientId
                AggrProducerMetrics result = apiInstance.getProducerMetrics(producerClientId, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getProducerMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$producerClientId = producerClientId_example; // String | Producer client identifier
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getProducerMetrics($producerClientId, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getProducerMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $producerClientId = producerClientId_example; # String | Producer client identifier
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getProducerMetrics(producerClientId => $producerClientId, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getProducerMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
producerClientId = producerClientId_example # String | Producer client identifier
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get producer metrics for the given producerClientId
    api_response = api_instance.get_producer_metrics(producerClientId, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getProducerMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.AggregatedMetricOperationsApi;

import java.io.File;
import java.util.*;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String topicName = topicName_example; // String | Name of the topic
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        String state = state_example; // String | State of the Client
        try {
            AggrTopicMetrics result = apiInstance.getTopicMetrics(topicName, duration, from, to, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getTopicMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.AggregatedMetricOperationsApi;

public class AggregatedMetricOperationsApiExample {

    public static void main(String[] args) {
        AggregatedMetricOperationsApi apiInstance = new AggregatedMetricOperationsApi();
        String topicName = topicName_example; // String | Name of the topic
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        String state = state_example; // String | State of the Client
        try {
            AggrTopicMetrics result = apiInstance.getTopicMetrics(topicName, duration, from, to, state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling AggregatedMetricOperationsApi#getTopicMetrics");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // Name of the topic
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)
String *state = state_example; // State of the Client (optional)

AggregatedMetricOperationsApi *apiInstance = [[AggregatedMetricOperationsApi alloc] init];

// Get topic metrics for the given topic
[apiInstance getTopicMetricsWith:topicName
    duration:duration
    from:from
    to:to
    state:state
              completionHandler: ^(AggrTopicMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.AggregatedMetricOperationsApi()
var topicName = topicName_example; // {{String}} Name of the topic
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789, // {{Long}} End of the time period. Provide '-1' to fetch the latest value
  'state': state_example // {{String}} State of the Client
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicMetrics(topicName, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicMetricsExample
    {
        public void main()
        {

            var apiInstance = new AggregatedMetricOperationsApi();
            var topicName = topicName_example;  // String | Name of the topic
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 
            var state = state_example;  // String | State of the Client (optional) 

            try
            {
                // Get topic metrics for the given topic
                AggrTopicMetrics result = apiInstance.getTopicMetrics(topicName, duration, from, to, state);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling AggregatedMetricOperationsApi.getTopicMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiAggregatedMetricOperationsApi();
$topicName = topicName_example; // String | Name of the topic
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
$state = state_example; // String | State of the Client

try {
    $result = $api_instance->getTopicMetrics($topicName, $duration, $from, $to, $state);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling AggregatedMetricOperationsApi->getTopicMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::AggregatedMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::AggregatedMetricOperationsApi->new();
my $topicName = topicName_example; # String | Name of the topic
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value
my $state = state_example; # String | State of the Client

eval { 
    my $result = $api_instance->getTopicMetrics(topicName => $topicName, duration => $duration, from => $from, to => $to, state => $state);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling AggregatedMetricOperationsApi->getTopicMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.AggregatedMetricOperationsApi()
topicName = topicName_example # String | Name of the topic
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)
state = state_example # String | State of the Client (optional)

try: 
    # Get topic metrics for the given topic
    api_response = api_instance.get_topic_metrics(topicName, duration=duration, from=from, to=to, state=state)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling AggregatedMetricOperationsApi->getTopicMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ApplicationContextRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class ApplicationContextRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        ApplicationContextRelatedOperationsApi apiInstance = new ApplicationContextRelatedOperationsApi();
        try {
            SMMVersion result = apiInstance.getSMMVersion();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ApplicationContextRelatedOperationsApi#getSMMVersion");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ApplicationContextRelatedOperationsApi;

public class ApplicationContextRelatedOperationsApiExample {

    public static void main(String[] args) {
        ApplicationContextRelatedOperationsApi apiInstance = new ApplicationContextRelatedOperationsApi();
        try {
            SMMVersion result = apiInstance.getSMMVersion();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ApplicationContextRelatedOperationsApi#getSMMVersion");
            e.printStackTrace();
        }
    }
}

ApplicationContextRelatedOperationsApi *apiInstance = [[ApplicationContextRelatedOperationsApi alloc] init];

// Returns version of SMM service
[apiInstance getSMMVersionWithCompletionHandler: 
              ^(SMMVersion output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ApplicationContextRelatedOperationsApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getSMMVersion(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getSMMVersionExample
    {
        public void main()
        {

            var apiInstance = new ApplicationContextRelatedOperationsApi();

            try
            {
                // Returns version of SMM service
                SMMVersion result = apiInstance.getSMMVersion();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ApplicationContextRelatedOperationsApi.getSMMVersion: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiApplicationContextRelatedOperationsApi();

try {
    $result = $api_instance->getSMMVersion();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ApplicationContextRelatedOperationsApi->getSMMVersion: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ApplicationContextRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::ApplicationContextRelatedOperationsApi->new();

eval { 
    my $result = $api_instance->getSMMVersion();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ApplicationContextRelatedOperationsApi->getSMMVersion: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ApplicationContextRelatedOperationsApi()

try: 
    # Returns version of SMM service
    api_response = api_instance.get_smm_version()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ApplicationContextRelatedOperationsApi->getSMMVersion: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.BrokerMetricsOperationsApi;

import java.io.File;
import java.util.*;

public class BrokerMetricsOperationsApiExample {

    public static void main(String[] args) {
        
        BrokerMetricsOperationsApi apiInstance = new BrokerMetricsOperationsApi();
        Integer brokerId = 56; // Integer | Broker identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            BrokerMetrics result = apiInstance.getBrokerMetrics(brokerId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling BrokerMetricsOperationsApi#getBrokerMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.BrokerMetricsOperationsApi;

public class BrokerMetricsOperationsApiExample {

    public static void main(String[] args) {
        BrokerMetricsOperationsApi apiInstance = new BrokerMetricsOperationsApi();
        Integer brokerId = 56; // Integer | Broker identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            BrokerMetrics result = apiInstance.getBrokerMetrics(brokerId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling BrokerMetricsOperationsApi#getBrokerMetrics");
            e.printStackTrace();
        }
    }
}

Integer *brokerId = 56; // Broker identifier
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

BrokerMetricsOperationsApi *apiInstance = [[BrokerMetricsOperationsApi alloc] init];

// Get broker metrics for given brokerId.
[apiInstance getBrokerMetricsWith:brokerId
    duration:duration
    from:from
    to:to
              completionHandler: ^(BrokerMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.BrokerMetricsOperationsApi()
var brokerId = 56; // {{Integer}} Broker identifier
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBrokerMetrics(brokerId, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokerMetricsExample
    {
        public void main()
        {

            var apiInstance = new BrokerMetricsOperationsApi();
            var brokerId = 56;  // Integer | Broker identifier
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get broker metrics for given brokerId.
                BrokerMetrics result = apiInstance.getBrokerMetrics(brokerId, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling BrokerMetricsOperationsApi.getBrokerMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiBrokerMetricsOperationsApi();
$brokerId = 56; // Integer | Broker identifier
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getBrokerMetrics($brokerId, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling BrokerMetricsOperationsApi->getBrokerMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::BrokerMetricsOperationsApi;

my $api_instance = WWW::SwaggerClient::BrokerMetricsOperationsApi->new();
my $brokerId = 56; # Integer | Broker identifier
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getBrokerMetrics(brokerId => $brokerId, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling BrokerMetricsOperationsApi->getBrokerMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.BrokerMetricsOperationsApi()
brokerId = 56 # Integer | Broker identifier
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get broker metrics for given brokerId.
    api_response = api_instance.get_broker_metrics(brokerId, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling BrokerMetricsOperationsApi->getBrokerMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.BrokersMetadataOperationsApi;

import java.io.File;
import java.util.*;

public class BrokersMetadataOperationsApiExample {

    public static void main(String[] args) {
        
        BrokersMetadataOperationsApi apiInstance = new BrokersMetadataOperationsApi();
        Integer brokerId = 56; // Integer | 
        try {
            BrokerNode result = apiInstance.getBroker(brokerId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling BrokersMetadataOperationsApi#getBroker");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.BrokersMetadataOperationsApi;

public class BrokersMetadataOperationsApiExample {

    public static void main(String[] args) {
        BrokersMetadataOperationsApi apiInstance = new BrokersMetadataOperationsApi();
        Integer brokerId = 56; // Integer | 
        try {
            BrokerNode result = apiInstance.getBroker(brokerId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling BrokersMetadataOperationsApi#getBroker");
            e.printStackTrace();
        }
    }
}

Integer *brokerId = 56; // 

BrokersMetadataOperationsApi *apiInstance = [[BrokersMetadataOperationsApi alloc] init];

// Returns broker node in the cluster with the given broker Id.
[apiInstance getBrokerWith:brokerId
              completionHandler: ^(BrokerNode output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.BrokersMetadataOperationsApi()
var brokerId = 56; // {{Integer}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBroker(brokerId, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokerExample
    {
        public void main()
        {

            var apiInstance = new BrokersMetadataOperationsApi();
            var brokerId = 56;  // Integer | 

            try
            {
                // Returns broker node in the cluster with the given broker Id.
                BrokerNode result = apiInstance.getBroker(brokerId);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling BrokersMetadataOperationsApi.getBroker: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiBrokersMetadataOperationsApi();
$brokerId = 56; // Integer | 

try {
    $result = $api_instance->getBroker($brokerId);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling BrokersMetadataOperationsApi->getBroker: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::BrokersMetadataOperationsApi;

my $api_instance = WWW::SwaggerClient::BrokersMetadataOperationsApi->new();
my $brokerId = 56; # Integer | 

eval { 
    my $result = $api_instance->getBroker(brokerId => $brokerId);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling BrokersMetadataOperationsApi->getBroker: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.BrokersMetadataOperationsApi()
brokerId = 56 # Integer | 

try: 
    # Returns broker node in the cluster with the given broker Id.
    api_response = api_instance.get_broker(brokerId)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling BrokersMetadataOperationsApi->getBroker: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.BrokersMetadataOperationsApi;

import java.io.File;
import java.util.*;

public class BrokersMetadataOperationsApiExample {

    public static void main(String[] args) {
        
        BrokersMetadataOperationsApi apiInstance = new BrokersMetadataOperationsApi();
        String brokerIds = brokerIds_example; // String | Comma separated broker identifiers
        try {
            array[BrokerNode] result = apiInstance.getBrokers(brokerIds);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling BrokersMetadataOperationsApi#getBrokers");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.BrokersMetadataOperationsApi;

public class BrokersMetadataOperationsApiExample {

    public static void main(String[] args) {
        BrokersMetadataOperationsApi apiInstance = new BrokersMetadataOperationsApi();
        String brokerIds = brokerIds_example; // String | Comma separated broker identifiers
        try {
            array[BrokerNode] result = apiInstance.getBrokers(brokerIds);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling BrokersMetadataOperationsApi#getBrokers");
            e.printStackTrace();
        }
    }
}

String *brokerIds = brokerIds_example; // Comma separated broker identifiers (optional)

BrokersMetadataOperationsApi *apiInstance = [[BrokersMetadataOperationsApi alloc] init];

// Returns all broker nodes in the cluster with the given brokerIds if they exist.
[apiInstance getBrokersWith:brokerIds
              completionHandler: ^(array[BrokerNode] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.BrokersMetadataOperationsApi()
var opts = { 
  'brokerIds': brokerIds_example // {{String}} Comma separated broker identifiers
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBrokers(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokersExample
    {
        public void main()
        {

            var apiInstance = new BrokersMetadataOperationsApi();
            var brokerIds = brokerIds_example;  // String | Comma separated broker identifiers (optional) 

            try
            {
                // Returns all broker nodes in the cluster with the given brokerIds if they exist.
                array[BrokerNode] result = apiInstance.getBrokers(brokerIds);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling BrokersMetadataOperationsApi.getBrokers: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiBrokersMetadataOperationsApi();
$brokerIds = brokerIds_example; // String | Comma separated broker identifiers

try {
    $result = $api_instance->getBrokers($brokerIds);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling BrokersMetadataOperationsApi->getBrokers: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::BrokersMetadataOperationsApi;

my $api_instance = WWW::SwaggerClient::BrokersMetadataOperationsApi->new();
my $brokerIds = brokerIds_example; # String | Comma separated broker identifiers

eval { 
    my $result = $api_instance->getBrokers(brokerIds => $brokerIds);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling BrokersMetadataOperationsApi->getBrokers: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.BrokersMetadataOperationsApi()
brokerIds = brokerIds_example # String | Comma separated broker identifiers (optional)

try: 
    # Returns all broker nodes in the cluster with the given brokerIds if they exist.
    api_response = api_instance.get_brokers(brokerIds=brokerIds)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling BrokersMetadataOperationsApi->getBrokers: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ClusterMetadataOperationsApi;

import java.io.File;
import java.util.*;

public class ClusterMetadataOperationsApiExample {

    public static void main(String[] args) {
        
        ClusterMetadataOperationsApi apiInstance = new ClusterMetadataOperationsApi();
        try {
            KafkaClusterInfo result = apiInstance.getClusterDetails();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ClusterMetadataOperationsApi#getClusterDetails");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ClusterMetadataOperationsApi;

public class ClusterMetadataOperationsApiExample {

    public static void main(String[] args) {
        ClusterMetadataOperationsApi apiInstance = new ClusterMetadataOperationsApi();
        try {
            KafkaClusterInfo result = apiInstance.getClusterDetails();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ClusterMetadataOperationsApi#getClusterDetails");
            e.printStackTrace();
        }
    }
}

ClusterMetadataOperationsApi *apiInstance = [[ClusterMetadataOperationsApi alloc] init];

// Get the kafka cluster details to which this service is connected to.
[apiInstance getClusterDetailsWithCompletionHandler: 
              ^(KafkaClusterInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ClusterMetadataOperationsApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getClusterDetails(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getClusterDetailsExample
    {
        public void main()
        {

            var apiInstance = new ClusterMetadataOperationsApi();

            try
            {
                // Get the kafka cluster details to which this service is connected to.
                KafkaClusterInfo result = apiInstance.getClusterDetails();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ClusterMetadataOperationsApi.getClusterDetails: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiClusterMetadataOperationsApi();

try {
    $result = $api_instance->getClusterDetails();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ClusterMetadataOperationsApi->getClusterDetails: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ClusterMetadataOperationsApi;

my $api_instance = WWW::SwaggerClient::ClusterMetadataOperationsApi->new();

eval { 
    my $result = $api_instance->getClusterDetails();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ClusterMetadataOperationsApi->getClusterDetails: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ClusterMetadataOperationsApi()

try: 
    # Get the kafka cluster details to which this service is connected to.
    api_response = api_instance.get_cluster_details()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ClusterMetadataOperationsApi->getClusterDetails: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

import java.io.File;
import java.util.*;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        try {
            array[ConsumerInfo] result = apiInstance.getAllConsumerInfo();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getAllConsumerInfo");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        try {
            array[ConsumerInfo] result = apiInstance.getAllConsumerInfo();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getAllConsumerInfo");
            e.printStackTrace();
        }
    }
}

ConsumerGroupRelatedDetails_Api *apiInstance = [[ConsumerGroupRelatedDetails_Api alloc] init];

// Get consumer group details for all clients.
[apiInstance getAllConsumerInfoWithCompletionHandler: 
              ^(array[ConsumerInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ConsumerGroupRelatedDetails_Api()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getAllConsumerInfo(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getAllConsumerInfoExample
    {
        public void main()
        {

            var apiInstance = new ConsumerGroupRelatedDetails_Api();

            try
            {
                // Get consumer group details for all clients.
                array[ConsumerInfo] result = apiInstance.getAllConsumerInfo();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ConsumerGroupRelatedDetails_Api.getAllConsumerInfo: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiConsumerGroupRelatedDetails_Api();

try {
    $result = $api_instance->getAllConsumerInfo();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ConsumerGroupRelatedDetails_Api->getAllConsumerInfo: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api;

my $api_instance = WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api->new();

eval { 
    my $result = $api_instance->getAllConsumerInfo();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ConsumerGroupRelatedDetails_Api->getAllConsumerInfo: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ConsumerGroupRelatedDetails_Api()

try: 
    # Get consumer group details for all clients.
    api_response = api_instance.get_all_consumer_info()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ConsumerGroupRelatedDetails_Api->getAllConsumerInfo: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

import java.io.File;
import java.util.*;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        String groupName = groupName_example; // String | Name of the consumer group
        try {
            ConsumerGroupInfo result = apiInstance.getConsumerGroupInfo(groupName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerGroupInfo");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        String groupName = groupName_example; // String | Name of the consumer group
        try {
            ConsumerGroupInfo result = apiInstance.getConsumerGroupInfo(groupName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerGroupInfo");
            e.printStackTrace();
        }
    }
}

String *groupName = groupName_example; // Name of the consumer group

ConsumerGroupRelatedDetails_Api *apiInstance = [[ConsumerGroupRelatedDetails_Api alloc] init];

// Get consumer group details for the given groupName `groupName`.
[apiInstance getConsumerGroupInfoWith:groupName
              completionHandler: ^(ConsumerGroupInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ConsumerGroupRelatedDetails_Api()
var groupName = groupName_example; // {{String}} Name of the consumer group

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getConsumerGroupInfo(groupName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getConsumerGroupInfoExample
    {
        public void main()
        {

            var apiInstance = new ConsumerGroupRelatedDetails_Api();
            var groupName = groupName_example;  // String | Name of the consumer group

            try
            {
                // Get consumer group details for the given groupName `groupName`.
                ConsumerGroupInfo result = apiInstance.getConsumerGroupInfo(groupName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ConsumerGroupRelatedDetails_Api.getConsumerGroupInfo: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiConsumerGroupRelatedDetails_Api();
$groupName = groupName_example; // String | Name of the consumer group

try {
    $result = $api_instance->getConsumerGroupInfo($groupName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroupInfo: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api;

my $api_instance = WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api->new();
my $groupName = groupName_example; # String | Name of the consumer group

eval { 
    my $result = $api_instance->getConsumerGroupInfo(groupName => $groupName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroupInfo: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ConsumerGroupRelatedDetails_Api()
groupName = groupName_example # String | Name of the consumer group

try: 
    # Get consumer group details for the given groupName `groupName`.
    api_response = api_instance.get_consumer_group_info(groupName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroupInfo: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

import java.io.File;
import java.util.*;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        try {
            array['String'] result = apiInstance.getConsumerGroupNames();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerGroupNames");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        try {
            array['String'] result = apiInstance.getConsumerGroupNames();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerGroupNames");
            e.printStackTrace();
        }
    }
}

ConsumerGroupRelatedDetails_Api *apiInstance = [[ConsumerGroupRelatedDetails_Api alloc] init];

// Get all consumer group names.
[apiInstance getConsumerGroupNamesWithCompletionHandler: 
              ^(array['String'] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ConsumerGroupRelatedDetails_Api()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getConsumerGroupNames(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getConsumerGroupNamesExample
    {
        public void main()
        {

            var apiInstance = new ConsumerGroupRelatedDetails_Api();

            try
            {
                // Get all consumer group names.
                array['String'] result = apiInstance.getConsumerGroupNames();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ConsumerGroupRelatedDetails_Api.getConsumerGroupNames: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiConsumerGroupRelatedDetails_Api();

try {
    $result = $api_instance->getConsumerGroupNames();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroupNames: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api;

my $api_instance = WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api->new();

eval { 
    my $result = $api_instance->getConsumerGroupNames();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroupNames: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ConsumerGroupRelatedDetails_Api()

try: 
    # Get all consumer group names.
    api_response = api_instance.get_consumer_group_names()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroupNames: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

import java.io.File;
import java.util.*;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        String state = state_example; // String | State of the Consumer Group
        try {
            array[ConsumerGroupInfo] result = apiInstance.getConsumerGroups(state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerGroups");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        String state = state_example; // String | State of the Consumer Group
        try {
            array[ConsumerGroupInfo] result = apiInstance.getConsumerGroups(state);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerGroups");
            e.printStackTrace();
        }
    }
}

String *state = state_example; // State of the Consumer Group (optional)

ConsumerGroupRelatedDetails_Api *apiInstance = [[ConsumerGroupRelatedDetails_Api alloc] init];

// Get all consumer group details.
[apiInstance getConsumerGroupsWith:state
              completionHandler: ^(array[ConsumerGroupInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ConsumerGroupRelatedDetails_Api()
var opts = { 
  'state': state_example // {{String}} State of the Consumer Group
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getConsumerGroups(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getConsumerGroupsExample
    {
        public void main()
        {

            var apiInstance = new ConsumerGroupRelatedDetails_Api();
            var state = state_example;  // String | State of the Consumer Group (optional) 

            try
            {
                // Get all consumer group details.
                array[ConsumerGroupInfo] result = apiInstance.getConsumerGroups(state);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ConsumerGroupRelatedDetails_Api.getConsumerGroups: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiConsumerGroupRelatedDetails_Api();
$state = state_example; // String | State of the Consumer Group

try {
    $result = $api_instance->getConsumerGroups($state);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroups: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api;

my $api_instance = WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api->new();
my $state = state_example; # String | State of the Consumer Group

eval { 
    my $result = $api_instance->getConsumerGroups(state => $state);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroups: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ConsumerGroupRelatedDetails_Api()
state = state_example # String | State of the Consumer Group (optional)

try: 
    # Get all consumer group details.
    api_response = api_instance.get_consumer_groups(state=state)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerGroups: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

import java.io.File;
import java.util.*;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        String clientId = clientId_example; // String | Consumer client identifier
        try {
            ConsumerInfo result = apiInstance.getConsumerInfo(clientId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerInfo");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ConsumerGroupRelatedDetails_Api;

public class ConsumerGroupRelatedDetails_ApiExample {

    public static void main(String[] args) {
        ConsumerGroupRelatedDetails_Api apiInstance = new ConsumerGroupRelatedDetails_Api();
        String clientId = clientId_example; // String | Consumer client identifier
        try {
            ConsumerInfo result = apiInstance.getConsumerInfo(clientId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerGroupRelatedDetails_Api#getConsumerInfo");
            e.printStackTrace();
        }
    }
}

String *clientId = clientId_example; // Consumer client identifier

ConsumerGroupRelatedDetails_Api *apiInstance = [[ConsumerGroupRelatedDetails_Api alloc] init];

// Get consumer group details for a given clientId.
[apiInstance getConsumerInfoWith:clientId
              completionHandler: ^(ConsumerInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ConsumerGroupRelatedDetails_Api()
var clientId = clientId_example; // {{String}} Consumer client identifier

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getConsumerInfo(clientId, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getConsumerInfoExample
    {
        public void main()
        {

            var apiInstance = new ConsumerGroupRelatedDetails_Api();
            var clientId = clientId_example;  // String | Consumer client identifier

            try
            {
                // Get consumer group details for a given clientId.
                ConsumerInfo result = apiInstance.getConsumerInfo(clientId);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ConsumerGroupRelatedDetails_Api.getConsumerInfo: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiConsumerGroupRelatedDetails_Api();
$clientId = clientId_example; // String | Consumer client identifier

try {
    $result = $api_instance->getConsumerInfo($clientId);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerInfo: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api;

my $api_instance = WWW::SwaggerClient::ConsumerGroupRelatedDetails_Api->new();
my $clientId = clientId_example; # String | Consumer client identifier

eval { 
    my $result = $api_instance->getConsumerInfo(clientId => $clientId);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerInfo: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ConsumerGroupRelatedDetails_Api()
clientId = clientId_example # String | Consumer client identifier

try: 
    # Get consumer group details for a given clientId.
    api_response = api_instance.get_consumer_info(clientId)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ConsumerGroupRelatedDetails_Api->getConsumerInfo: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ConsumerMetricOperationsApi;

import java.io.File;
import java.util.*;

public class ConsumerMetricOperationsApiExample {

    public static void main(String[] args) {
        
        ConsumerMetricOperationsApi apiInstance = new ConsumerMetricOperationsApi();
        String groupId = groupId_example; // String | Consumer group identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            ConsumerGroupMetrics result = apiInstance.getConsumerGroupMetrics(groupId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerMetricOperationsApi#getConsumerGroupMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ConsumerMetricOperationsApi;

public class ConsumerMetricOperationsApiExample {

    public static void main(String[] args) {
        ConsumerMetricOperationsApi apiInstance = new ConsumerMetricOperationsApi();
        String groupId = groupId_example; // String | Consumer group identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            ConsumerGroupMetrics result = apiInstance.getConsumerGroupMetrics(groupId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ConsumerMetricOperationsApi#getConsumerGroupMetrics");
            e.printStackTrace();
        }
    }
}

String *groupId = groupId_example; // Consumer group identifier
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

ConsumerMetricOperationsApi *apiInstance = [[ConsumerMetricOperationsApi alloc] init];

// Get timeline metrics for a consumer group. This will return per partition metrics for a consumer group.
[apiInstance getConsumerGroupMetricsWith:groupId
    duration:duration
    from:from
    to:to
              completionHandler: ^(ConsumerGroupMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ConsumerMetricOperationsApi()
var groupId = groupId_example; // {{String}} Consumer group identifier
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getConsumerGroupMetrics(groupId, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getConsumerGroupMetricsExample
    {
        public void main()
        {

            var apiInstance = new ConsumerMetricOperationsApi();
            var groupId = groupId_example;  // String | Consumer group identifier
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get timeline metrics for a consumer group. This will return per partition metrics for a consumer group.
                ConsumerGroupMetrics result = apiInstance.getConsumerGroupMetrics(groupId, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ConsumerMetricOperationsApi.getConsumerGroupMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiConsumerMetricOperationsApi();
$groupId = groupId_example; // String | Consumer group identifier
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getConsumerGroupMetrics($groupId, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ConsumerMetricOperationsApi->getConsumerGroupMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ConsumerMetricOperationsApi;

my $api_instance = WWW::SwaggerClient::ConsumerMetricOperationsApi->new();
my $groupId = groupId_example; # String | Consumer group identifier
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getConsumerGroupMetrics(groupId => $groupId, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ConsumerMetricOperationsApi->getConsumerGroupMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ConsumerMetricOperationsApi()
groupId = groupId_example # String | Consumer group identifier
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get timeline metrics for a consumer group. This will return per partition metrics for a consumer group.
    api_response = api_instance.get_consumer_group_metrics(groupId, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ConsumerMetricOperationsApi->getConsumerGroupMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ProducerMetricsOperationsApi;

import java.io.File;
import java.util.*;

public class ProducerMetricsOperationsApiExample {

    public static void main(String[] args) {
        
        ProducerMetricsOperationsApi apiInstance = new ProducerMetricsOperationsApi();
        String state = state_example; // String | State of the Producer
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            array[ProducerMetrics] result = apiInstance.getAllProducerMetrics(state, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ProducerMetricsOperationsApi#getAllProducerMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ProducerMetricsOperationsApi;

public class ProducerMetricsOperationsApiExample {

    public static void main(String[] args) {
        ProducerMetricsOperationsApi apiInstance = new ProducerMetricsOperationsApi();
        String state = state_example; // String | State of the Producer
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            array[ProducerMetrics] result = apiInstance.getAllProducerMetrics(state, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ProducerMetricsOperationsApi#getAllProducerMetrics");
            e.printStackTrace();
        }
    }
}

String *state = state_example; // State of the Producer (optional)
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

ProducerMetricsOperationsApi *apiInstance = [[ProducerMetricsOperationsApi alloc] init];

// Get producer metrics for all the alive producers
[apiInstance getAllProducerMetricsWith:state
    duration:duration
    from:from
    to:to
              completionHandler: ^(array[ProducerMetrics] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ProducerMetricsOperationsApi()
var opts = { 
  'state': state_example, // {{String}} State of the Producer
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getAllProducerMetrics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getAllProducerMetricsExample
    {
        public void main()
        {

            var apiInstance = new ProducerMetricsOperationsApi();
            var state = state_example;  // String | State of the Producer (optional) 
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get producer metrics for all the alive producers
                array[ProducerMetrics] result = apiInstance.getAllProducerMetrics(state, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ProducerMetricsOperationsApi.getAllProducerMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiProducerMetricsOperationsApi();
$state = state_example; // String | State of the Producer
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getAllProducerMetrics($state, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ProducerMetricsOperationsApi->getAllProducerMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ProducerMetricsOperationsApi;

my $api_instance = WWW::SwaggerClient::ProducerMetricsOperationsApi->new();
my $state = state_example; # String | State of the Producer
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getAllProducerMetrics(state => $state, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ProducerMetricsOperationsApi->getAllProducerMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ProducerMetricsOperationsApi()
state = state_example # String | State of the Producer (optional)
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get producer metrics for all the alive producers
    api_response = api_instance.get_all_producer_metrics(state=state, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ProducerMetricsOperationsApi->getAllProducerMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ProducerMetricsOperationsApi;

import java.io.File;
import java.util.*;

public class ProducerMetricsOperationsApiExample {

    public static void main(String[] args) {
        
        ProducerMetricsOperationsApi apiInstance = new ProducerMetricsOperationsApi();
        String producerClientId = producerClientId_example; // String | Producer client identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            ProducerMetrics result = apiInstance.getProducerMetrics(producerClientId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ProducerMetricsOperationsApi#getProducerMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ProducerMetricsOperationsApi;

public class ProducerMetricsOperationsApiExample {

    public static void main(String[] args) {
        ProducerMetricsOperationsApi apiInstance = new ProducerMetricsOperationsApi();
        String producerClientId = producerClientId_example; // String | Producer client identifier
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            ProducerMetrics result = apiInstance.getProducerMetrics(producerClientId, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ProducerMetricsOperationsApi#getProducerMetrics");
            e.printStackTrace();
        }
    }
}

String *producerClientId = producerClientId_example; // Producer client identifier
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

ProducerMetricsOperationsApi *apiInstance = [[ProducerMetricsOperationsApi alloc] init];

// Get producer metrics for the given producerClientId
[apiInstance getProducerMetricsWith:producerClientId
    duration:duration
    from:from
    to:to
              completionHandler: ^(ProducerMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ProducerMetricsOperationsApi()
var producerClientId = producerClientId_example; // {{String}} Producer client identifier
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getProducerMetrics(producerClientId, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getProducerMetricsExample
    {
        public void main()
        {

            var apiInstance = new ProducerMetricsOperationsApi();
            var producerClientId = producerClientId_example;  // String | Producer client identifier
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get producer metrics for the given producerClientId
                ProducerMetrics result = apiInstance.getProducerMetrics(producerClientId, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ProducerMetricsOperationsApi.getProducerMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiProducerMetricsOperationsApi();
$producerClientId = producerClientId_example; // String | Producer client identifier
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getProducerMetrics($producerClientId, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ProducerMetricsOperationsApi->getProducerMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ProducerMetricsOperationsApi;

my $api_instance = WWW::SwaggerClient::ProducerMetricsOperationsApi->new();
my $producerClientId = producerClientId_example; # String | Producer client identifier
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getProducerMetrics(producerClientId => $producerClientId, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ProducerMetricsOperationsApi->getProducerMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ProducerMetricsOperationsApi()
producerClientId = producerClientId_example # String | Producer client identifier
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get producer metrics for the given producerClientId
    api_response = api_instance.get_producer_metrics(producerClientId, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ProducerMetricsOperationsApi->getProducerMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ResourceConfigurationOperationsApi;

import java.io.File;
import java.util.*;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        try {
            array[KafkaResourceConfig] result = apiInstance.getAllBrokerDetails();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getAllBrokerDetails");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ResourceConfigurationOperationsApi;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        try {
            array[KafkaResourceConfig] result = apiInstance.getAllBrokerDetails();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getAllBrokerDetails");
            e.printStackTrace();
        }
    }
}

ResourceConfigurationOperationsApi *apiInstance = [[ResourceConfigurationOperationsApi alloc] init];

// Get kafka configurations for the given brokerIds. if brokerIds parameter does not have any value then configuration for all brokers is returned.
[apiInstance getAllBrokerDetailsWithCompletionHandler: 
              ^(array[KafkaResourceConfig] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ResourceConfigurationOperationsApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getAllBrokerDetails(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getAllBrokerDetailsExample
    {
        public void main()
        {

            var apiInstance = new ResourceConfigurationOperationsApi();

            try
            {
                // Get kafka configurations for the given brokerIds. if brokerIds parameter does not have any value then configuration for all brokers is returned.
                array[KafkaResourceConfig] result = apiInstance.getAllBrokerDetails();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ResourceConfigurationOperationsApi.getAllBrokerDetails: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiResourceConfigurationOperationsApi();

try {
    $result = $api_instance->getAllBrokerDetails();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ResourceConfigurationOperationsApi->getAllBrokerDetails: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ResourceConfigurationOperationsApi;

my $api_instance = WWW::SwaggerClient::ResourceConfigurationOperationsApi->new();

eval { 
    my $result = $api_instance->getAllBrokerDetails();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ResourceConfigurationOperationsApi->getAllBrokerDetails: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ResourceConfigurationOperationsApi()

try: 
    # Get kafka configurations for the given brokerIds. if brokerIds parameter does not have any value then configuration for all brokers is returned.
    api_response = api_instance.get_all_broker_details()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ResourceConfigurationOperationsApi->getAllBrokerDetails: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ResourceConfigurationOperationsApi;

import java.io.File;
import java.util.*;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        try {
            array[KafkaResourceConfig] result = apiInstance.getAllTopicConfigs();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getAllTopicConfigs");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ResourceConfigurationOperationsApi;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        try {
            array[KafkaResourceConfig] result = apiInstance.getAllTopicConfigs();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getAllTopicConfigs");
            e.printStackTrace();
        }
    }
}

ResourceConfigurationOperationsApi *apiInstance = [[ResourceConfigurationOperationsApi alloc] init];

// Get kafka configurations for all topics.
[apiInstance getAllTopicConfigsWithCompletionHandler: 
              ^(array[KafkaResourceConfig] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ResourceConfigurationOperationsApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getAllTopicConfigs(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getAllTopicConfigsExample
    {
        public void main()
        {

            var apiInstance = new ResourceConfigurationOperationsApi();

            try
            {
                // Get kafka configurations for all topics.
                array[KafkaResourceConfig] result = apiInstance.getAllTopicConfigs();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ResourceConfigurationOperationsApi.getAllTopicConfigs: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiResourceConfigurationOperationsApi();

try {
    $result = $api_instance->getAllTopicConfigs();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ResourceConfigurationOperationsApi->getAllTopicConfigs: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ResourceConfigurationOperationsApi;

my $api_instance = WWW::SwaggerClient::ResourceConfigurationOperationsApi->new();

eval { 
    my $result = $api_instance->getAllTopicConfigs();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ResourceConfigurationOperationsApi->getAllTopicConfigs: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ResourceConfigurationOperationsApi()

try: 
    # Get kafka configurations for all topics.
    api_response = api_instance.get_all_topic_configs()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ResourceConfigurationOperationsApi->getAllTopicConfigs: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ResourceConfigurationOperationsApi;

import java.io.File;
import java.util.*;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        String brokerId = brokerId_example; // String | 
        try {
            KafkaResourceConfig result = apiInstance.getBrokerDetails(brokerId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getBrokerDetails");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ResourceConfigurationOperationsApi;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        String brokerId = brokerId_example; // String | 
        try {
            KafkaResourceConfig result = apiInstance.getBrokerDetails(brokerId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getBrokerDetails");
            e.printStackTrace();
        }
    }
}

String *brokerId = brokerId_example; // 

ResourceConfigurationOperationsApi *apiInstance = [[ResourceConfigurationOperationsApi alloc] init];

// Get kafka configurations for the given brokerId.
[apiInstance getBrokerDetailsWith:brokerId
              completionHandler: ^(KafkaResourceConfig output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ResourceConfigurationOperationsApi()
var brokerId = brokerId_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBrokerDetails(brokerId, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokerDetailsExample
    {
        public void main()
        {

            var apiInstance = new ResourceConfigurationOperationsApi();
            var brokerId = brokerId_example;  // String | 

            try
            {
                // Get kafka configurations for the given brokerId.
                KafkaResourceConfig result = apiInstance.getBrokerDetails(brokerId);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ResourceConfigurationOperationsApi.getBrokerDetails: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiResourceConfigurationOperationsApi();
$brokerId = brokerId_example; // String | 

try {
    $result = $api_instance->getBrokerDetails($brokerId);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ResourceConfigurationOperationsApi->getBrokerDetails: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ResourceConfigurationOperationsApi;

my $api_instance = WWW::SwaggerClient::ResourceConfigurationOperationsApi->new();
my $brokerId = brokerId_example; # String | 

eval { 
    my $result = $api_instance->getBrokerDetails(brokerId => $brokerId);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ResourceConfigurationOperationsApi->getBrokerDetails: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ResourceConfigurationOperationsApi()
brokerId = brokerId_example # String | 

try: 
    # Get kafka configurations for the given brokerId.
    api_response = api_instance.get_broker_details(brokerId)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ResourceConfigurationOperationsApi->getBrokerDetails: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.ResourceConfigurationOperationsApi;

import java.io.File;
import java.util.*;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            KafkaResourceConfig result = apiInstance.getTopicConfigs(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getTopicConfigs");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.ResourceConfigurationOperationsApi;

public class ResourceConfigurationOperationsApiExample {

    public static void main(String[] args) {
        ResourceConfigurationOperationsApi apiInstance = new ResourceConfigurationOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            KafkaResourceConfig result = apiInstance.getTopicConfigs(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling ResourceConfigurationOperationsApi#getTopicConfigs");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

ResourceConfigurationOperationsApi *apiInstance = [[ResourceConfigurationOperationsApi alloc] init];

// Get kafka configurations for a topic with given topicName.
[apiInstance getTopicConfigsWith:topicName
              completionHandler: ^(KafkaResourceConfig output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.ResourceConfigurationOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicConfigs(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicConfigsExample
    {
        public void main()
        {

            var apiInstance = new ResourceConfigurationOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Get kafka configurations for a topic with given topicName.
                KafkaResourceConfig result = apiInstance.getTopicConfigs(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling ResourceConfigurationOperationsApi.getTopicConfigs: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiResourceConfigurationOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getTopicConfigs($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling ResourceConfigurationOperationsApi->getTopicConfigs: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::ResourceConfigurationOperationsApi;

my $api_instance = WWW::SwaggerClient::ResourceConfigurationOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getTopicConfigs(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling ResourceConfigurationOperationsApi->getTopicConfigs: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ResourceConfigurationOperationsApi()
topicName = topicName_example # String | 

try: 
    # Get kafka configurations for a topic with given topicName.
    api_response = api_instance.get_topic_configs(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ResourceConfigurationOperationsApi->getTopicConfigs: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SchemaRegistryOperationsApi;

import java.io.File;
import java.util.*;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            array[SchemaVersionInfo] result = apiInstance.getKeySchemaVersionInfos(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#getKeySchemaVersionInfos");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SchemaRegistryOperationsApi;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            array[SchemaVersionInfo] result = apiInstance.getKeySchemaVersionInfos(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#getKeySchemaVersionInfos");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

SchemaRegistryOperationsApi *apiInstance = [[SchemaRegistryOperationsApi alloc] init];

// Get schema versions for the given kafka topic name
[apiInstance getKeySchemaVersionInfosWith:topicName
              completionHandler: ^(array[SchemaVersionInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SchemaRegistryOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getKeySchemaVersionInfos(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getKeySchemaVersionInfosExample
    {
        public void main()
        {

            var apiInstance = new SchemaRegistryOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Get schema versions for the given kafka topic name
                array[SchemaVersionInfo] result = apiInstance.getKeySchemaVersionInfos(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SchemaRegistryOperationsApi.getKeySchemaVersionInfos: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSchemaRegistryOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getKeySchemaVersionInfos($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SchemaRegistryOperationsApi->getKeySchemaVersionInfos: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SchemaRegistryOperationsApi;

my $api_instance = WWW::SwaggerClient::SchemaRegistryOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getKeySchemaVersionInfos(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SchemaRegistryOperationsApi->getKeySchemaVersionInfos: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SchemaRegistryOperationsApi()
topicName = topicName_example # String | 

try: 
    # Get schema versions for the given kafka topic name
    api_response = api_instance.get_key_schema_version_infos(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SchemaRegistryOperationsApi->getKeySchemaVersionInfos: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SchemaRegistryOperationsApi;

import java.io.File;
import java.util.*;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            TopicSchemaMapping result = apiInstance.getSchemaMetaForTopic(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#getSchemaMetaForTopic");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SchemaRegistryOperationsApi;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            TopicSchemaMapping result = apiInstance.getSchemaMetaForTopic(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#getSchemaMetaForTopic");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

SchemaRegistryOperationsApi *apiInstance = [[SchemaRegistryOperationsApi alloc] init];

// Schema mapping for a given kafka topic name
[apiInstance getSchemaMetaForTopicWith:topicName
              completionHandler: ^(TopicSchemaMapping output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SchemaRegistryOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getSchemaMetaForTopic(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getSchemaMetaForTopicExample
    {
        public void main()
        {

            var apiInstance = new SchemaRegistryOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Schema mapping for a given kafka topic name
                TopicSchemaMapping result = apiInstance.getSchemaMetaForTopic(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SchemaRegistryOperationsApi.getSchemaMetaForTopic: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSchemaRegistryOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getSchemaMetaForTopic($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SchemaRegistryOperationsApi->getSchemaMetaForTopic: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SchemaRegistryOperationsApi;

my $api_instance = WWW::SwaggerClient::SchemaRegistryOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getSchemaMetaForTopic(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SchemaRegistryOperationsApi->getSchemaMetaForTopic: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SchemaRegistryOperationsApi()
topicName = topicName_example # String | 

try: 
    # Schema mapping for a given kafka topic name
    api_response = api_instance.get_schema_meta_for_topic(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SchemaRegistryOperationsApi->getSchemaMetaForTopic: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SchemaRegistryOperationsApi;

import java.io.File;
import java.util.*;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            array[SchemaVersionInfo] result = apiInstance.getValueSchemaVersionInfos(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#getValueSchemaVersionInfos");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SchemaRegistryOperationsApi;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            array[SchemaVersionInfo] result = apiInstance.getValueSchemaVersionInfos(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#getValueSchemaVersionInfos");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

SchemaRegistryOperationsApi *apiInstance = [[SchemaRegistryOperationsApi alloc] init];

// Get schema versions for the given kafka topic name
[apiInstance getValueSchemaVersionInfosWith:topicName
              completionHandler: ^(array[SchemaVersionInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SchemaRegistryOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getValueSchemaVersionInfos(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getValueSchemaVersionInfosExample
    {
        public void main()
        {

            var apiInstance = new SchemaRegistryOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Get schema versions for the given kafka topic name
                array[SchemaVersionInfo] result = apiInstance.getValueSchemaVersionInfos(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SchemaRegistryOperationsApi.getValueSchemaVersionInfos: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSchemaRegistryOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getValueSchemaVersionInfos($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SchemaRegistryOperationsApi->getValueSchemaVersionInfos: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SchemaRegistryOperationsApi;

my $api_instance = WWW::SwaggerClient::SchemaRegistryOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getValueSchemaVersionInfos(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SchemaRegistryOperationsApi->getValueSchemaVersionInfos: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SchemaRegistryOperationsApi()
topicName = topicName_example # String | 

try: 
    # Get schema versions for the given kafka topic name
    api_response = api_instance.get_value_schema_version_infos(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SchemaRegistryOperationsApi->getValueSchemaVersionInfos: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SchemaRegistryOperationsApi;

import java.io.File;
import java.util.*;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        TopicSchemaMapping body = ; // TopicSchemaMapping | 
        try {
            Long result = apiInstance.registerTopicSchemaMeta(topicName, body);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#registerTopicSchemaMeta");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SchemaRegistryOperationsApi;

public class SchemaRegistryOperationsApiExample {

    public static void main(String[] args) {
        SchemaRegistryOperationsApi apiInstance = new SchemaRegistryOperationsApi();
        String topicName = topicName_example; // String | 
        TopicSchemaMapping body = ; // TopicSchemaMapping | 
        try {
            Long result = apiInstance.registerTopicSchemaMeta(topicName, body);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SchemaRegistryOperationsApi#registerTopicSchemaMeta");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 
TopicSchemaMapping *body = ; //  (optional)

SchemaRegistryOperationsApi *apiInstance = [[SchemaRegistryOperationsApi alloc] init];

// Register a schema name for a kafka topic name
[apiInstance registerTopicSchemaMetaWith:topicName
    body:body
              completionHandler: ^(Long output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SchemaRegistryOperationsApi()
var topicName = topicName_example; // {{String}} 
var opts = { 
  'body':  // {{TopicSchemaMapping}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.registerTopicSchemaMeta(topicName, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class registerTopicSchemaMetaExample
    {
        public void main()
        {

            var apiInstance = new SchemaRegistryOperationsApi();
            var topicName = topicName_example;  // String | 
            var body = new TopicSchemaMapping(); // TopicSchemaMapping |  (optional) 

            try
            {
                // Register a schema name for a kafka topic name
                Long result = apiInstance.registerTopicSchemaMeta(topicName, body);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SchemaRegistryOperationsApi.registerTopicSchemaMeta: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSchemaRegistryOperationsApi();
$topicName = topicName_example; // String | 
$body = ; // TopicSchemaMapping | 

try {
    $result = $api_instance->registerTopicSchemaMeta($topicName, $body);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SchemaRegistryOperationsApi->registerTopicSchemaMeta: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SchemaRegistryOperationsApi;

my $api_instance = WWW::SwaggerClient::SchemaRegistryOperationsApi->new();
my $topicName = topicName_example; # String | 
my $body = WWW::SwaggerClient::Object::TopicSchemaMapping->new(); # TopicSchemaMapping | 

eval { 
    my $result = $api_instance->registerTopicSchemaMeta(topicName => $topicName, body => $body);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SchemaRegistryOperationsApi->registerTopicSchemaMeta: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SchemaRegistryOperationsApi()
topicName = topicName_example # String | 
body =  # TopicSchemaMapping |  (optional)

try: 
    # Register a schema name for a kafka topic name
    api_response = api_instance.register_topic_schema_meta(topicName, body=body)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SchemaRegistryOperationsApi->registerTopicSchemaMeta: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SearchRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String brokerIds = brokerIds_example; // String | Comma separated broker identifiers
        try {
            array[KafkaResourceConfig] result = apiInstance.getBrokerConfigs(brokerIds);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getBrokerConfigs");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SearchRelatedOperationsApi;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String brokerIds = brokerIds_example; // String | Comma separated broker identifiers
        try {
            array[KafkaResourceConfig] result = apiInstance.getBrokerConfigs(brokerIds);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getBrokerConfigs");
            e.printStackTrace();
        }
    }
}

String *brokerIds = brokerIds_example; // Comma separated broker identifiers (optional)

SearchRelatedOperationsApi *apiInstance = [[SearchRelatedOperationsApi alloc] init];

// Get kafka configurations for the given brokerIds.
[apiInstance getBrokerConfigsWith:brokerIds
              completionHandler: ^(array[KafkaResourceConfig] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SearchRelatedOperationsApi()
var opts = { 
  'brokerIds': brokerIds_example // {{String}} Comma separated broker identifiers
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBrokerConfigs(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokerConfigsExample
    {
        public void main()
        {

            var apiInstance = new SearchRelatedOperationsApi();
            var brokerIds = brokerIds_example;  // String | Comma separated broker identifiers (optional) 

            try
            {
                // Get kafka configurations for the given brokerIds.
                array[KafkaResourceConfig] result = apiInstance.getBrokerConfigs(brokerIds);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SearchRelatedOperationsApi.getBrokerConfigs: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSearchRelatedOperationsApi();
$brokerIds = brokerIds_example; // String | Comma separated broker identifiers

try {
    $result = $api_instance->getBrokerConfigs($brokerIds);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SearchRelatedOperationsApi->getBrokerConfigs: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SearchRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::SearchRelatedOperationsApi->new();
my $brokerIds = brokerIds_example; # String | Comma separated broker identifiers

eval { 
    my $result = $api_instance->getBrokerConfigs(brokerIds => $brokerIds);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SearchRelatedOperationsApi->getBrokerConfigs: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SearchRelatedOperationsApi()
brokerIds = brokerIds_example # String | Comma separated broker identifiers (optional)

try: 
    # Get kafka configurations for the given brokerIds.
    api_response = api_instance.get_broker_configs(brokerIds=brokerIds)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SearchRelatedOperationsApi->getBrokerConfigs: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SearchRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String brokerIds = brokerIds_example; // String | Comma separated broker identifiers
        try {
            array[BrokerNode] result = apiInstance.getBrokers(brokerIds);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getBrokers");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SearchRelatedOperationsApi;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String brokerIds = brokerIds_example; // String | Comma separated broker identifiers
        try {
            array[BrokerNode] result = apiInstance.getBrokers(brokerIds);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getBrokers");
            e.printStackTrace();
        }
    }
}

String *brokerIds = brokerIds_example; // Comma separated broker identifiers (optional)

SearchRelatedOperationsApi *apiInstance = [[SearchRelatedOperationsApi alloc] init];

// Returns broker nodes in the cluster with the given brokerIds if they exist.
[apiInstance getBrokersWith:brokerIds
              completionHandler: ^(array[BrokerNode] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SearchRelatedOperationsApi()
var opts = { 
  'brokerIds': brokerIds_example // {{String}} Comma separated broker identifiers
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getBrokers(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getBrokersExample
    {
        public void main()
        {

            var apiInstance = new SearchRelatedOperationsApi();
            var brokerIds = brokerIds_example;  // String | Comma separated broker identifiers (optional) 

            try
            {
                // Returns broker nodes in the cluster with the given brokerIds if they exist.
                array[BrokerNode] result = apiInstance.getBrokers(brokerIds);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SearchRelatedOperationsApi.getBrokers: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSearchRelatedOperationsApi();
$brokerIds = brokerIds_example; // String | Comma separated broker identifiers

try {
    $result = $api_instance->getBrokers($brokerIds);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SearchRelatedOperationsApi->getBrokers: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SearchRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::SearchRelatedOperationsApi->new();
my $brokerIds = brokerIds_example; # String | Comma separated broker identifiers

eval { 
    my $result = $api_instance->getBrokers(brokerIds => $brokerIds);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SearchRelatedOperationsApi->getBrokers: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SearchRelatedOperationsApi()
brokerIds = brokerIds_example # String | Comma separated broker identifiers (optional)

try: 
    # Returns broker nodes in the cluster with the given brokerIds if they exist.
    api_response = api_instance.get_brokers(brokerIds=brokerIds)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SearchRelatedOperationsApi->getBrokers: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SearchRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String topicNames = topicNames_example; // String | Comma separated topic names
        try {
            array[KafkaResourceConfig] result = apiInstance.getTopicConfigs(topicNames);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getTopicConfigs");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SearchRelatedOperationsApi;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String topicNames = topicNames_example; // String | Comma separated topic names
        try {
            array[KafkaResourceConfig] result = apiInstance.getTopicConfigs(topicNames);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getTopicConfigs");
            e.printStackTrace();
        }
    }
}

String *topicNames = topicNames_example; // Comma separated topic names (optional)

SearchRelatedOperationsApi *apiInstance = [[SearchRelatedOperationsApi alloc] init];

// Get kafka configurations at topic level for given topicNames
[apiInstance getTopicConfigsWith:topicNames
              completionHandler: ^(array[KafkaResourceConfig] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SearchRelatedOperationsApi()
var opts = { 
  'topicNames': topicNames_example // {{String}} Comma separated topic names
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicConfigs(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicConfigsExample
    {
        public void main()
        {

            var apiInstance = new SearchRelatedOperationsApi();
            var topicNames = topicNames_example;  // String | Comma separated topic names (optional) 

            try
            {
                // Get kafka configurations at topic level for given topicNames
                array[KafkaResourceConfig] result = apiInstance.getTopicConfigs(topicNames);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SearchRelatedOperationsApi.getTopicConfigs: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSearchRelatedOperationsApi();
$topicNames = topicNames_example; // String | Comma separated topic names

try {
    $result = $api_instance->getTopicConfigs($topicNames);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SearchRelatedOperationsApi->getTopicConfigs: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SearchRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::SearchRelatedOperationsApi->new();
my $topicNames = topicNames_example; # String | Comma separated topic names

eval { 
    my $result = $api_instance->getTopicConfigs(topicNames => $topicNames);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SearchRelatedOperationsApi->getTopicConfigs: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SearchRelatedOperationsApi()
topicNames = topicNames_example # String | Comma separated topic names (optional)

try: 
    # Get kafka configurations at topic level for given topicNames
    api_response = api_instance.get_topic_configs(topicNames=topicNames)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SearchRelatedOperationsApi->getTopicConfigs: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SearchRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String topicNames = topicNames_example; // String | Comma separated topic names
        try {
            array[TopicInfo] result = apiInstance.getTopicDetails(topicNames);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getTopicDetails");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SearchRelatedOperationsApi;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String topicNames = topicNames_example; // String | Comma separated topic names
        try {
            array[TopicInfo] result = apiInstance.getTopicDetails(topicNames);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getTopicDetails");
            e.printStackTrace();
        }
    }
}

String *topicNames = topicNames_example; // Comma separated topic names (optional)

SearchRelatedOperationsApi *apiInstance = [[SearchRelatedOperationsApi alloc] init];

// Get respective details for given topicNames.
[apiInstance getTopicDetailsWith:topicNames
              completionHandler: ^(array[TopicInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SearchRelatedOperationsApi()
var opts = { 
  'topicNames': topicNames_example // {{String}} Comma separated topic names
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicDetails(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicDetailsExample
    {
        public void main()
        {

            var apiInstance = new SearchRelatedOperationsApi();
            var topicNames = topicNames_example;  // String | Comma separated topic names (optional) 

            try
            {
                // Get respective details for given topicNames.
                array[TopicInfo] result = apiInstance.getTopicDetails(topicNames);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SearchRelatedOperationsApi.getTopicDetails: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSearchRelatedOperationsApi();
$topicNames = topicNames_example; // String | Comma separated topic names

try {
    $result = $api_instance->getTopicDetails($topicNames);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SearchRelatedOperationsApi->getTopicDetails: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SearchRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::SearchRelatedOperationsApi->new();
my $topicNames = topicNames_example; # String | Comma separated topic names

eval { 
    my $result = $api_instance->getTopicDetails(topicNames => $topicNames);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SearchRelatedOperationsApi->getTopicDetails: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SearchRelatedOperationsApi()
topicNames = topicNames_example # String | Comma separated topic names (optional)

try: 
    # Get respective details for given topicNames.
    api_response = api_instance.get_topic_details(topicNames=topicNames)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SearchRelatedOperationsApi->getTopicDetails: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SearchRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String partitions = partitions_example; // String | Comma separated topic partition values
        try {
            TopicPartitionInfos result = apiInstance.getTopicPartitionInfos(partitions);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getTopicPartitionInfos");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SearchRelatedOperationsApi;

public class SearchRelatedOperationsApiExample {

    public static void main(String[] args) {
        SearchRelatedOperationsApi apiInstance = new SearchRelatedOperationsApi();
        String partitions = partitions_example; // String | Comma separated topic partition values
        try {
            TopicPartitionInfos result = apiInstance.getTopicPartitionInfos(partitions);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SearchRelatedOperationsApi#getTopicPartitionInfos");
            e.printStackTrace();
        }
    }
}

String *partitions = partitions_example; // Comma separated topic partition values (optional)

SearchRelatedOperationsApi *apiInstance = [[SearchRelatedOperationsApi alloc] init];

// Get a list of topic partitions with respective details for the given collection of topicPartitions which exist in target Kafka cluster.
[apiInstance getTopicPartitionInfosWith:partitions
              completionHandler: ^(TopicPartitionInfos output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SearchRelatedOperationsApi()
var opts = { 
  'partitions': partitions_example // {{String}} Comma separated topic partition values
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicPartitionInfos(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicPartitionInfosExample
    {
        public void main()
        {

            var apiInstance = new SearchRelatedOperationsApi();
            var partitions = partitions_example;  // String | Comma separated topic partition values (optional) 

            try
            {
                // Get a list of topic partitions with respective details for the given collection of topicPartitions which exist in target Kafka cluster.
                TopicPartitionInfos result = apiInstance.getTopicPartitionInfos(partitions);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SearchRelatedOperationsApi.getTopicPartitionInfos: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSearchRelatedOperationsApi();
$partitions = partitions_example; // String | Comma separated topic partition values

try {
    $result = $api_instance->getTopicPartitionInfos($partitions);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SearchRelatedOperationsApi->getTopicPartitionInfos: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SearchRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::SearchRelatedOperationsApi->new();
my $partitions = partitions_example; # String | Comma separated topic partition values

eval { 
    my $result = $api_instance->getTopicPartitionInfos(partitions => $partitions);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SearchRelatedOperationsApi->getTopicPartitionInfos: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SearchRelatedOperationsApi()
partitions = partitions_example # String | Comma separated topic partition values (optional)

try: 
    # Get a list of topic partitions with respective details for the given collection of topicPartitions which exist in target Kafka cluster.
    api_response = api_instance.get_topic_partition_infos(partitions=partitions)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SearchRelatedOperationsApi->getTopicPartitionInfos: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.SerdesRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class SerdesRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        SerdesRelatedOperationsApi apiInstance = new SerdesRelatedOperationsApi();
        try {
            SerdesMappings result = apiInstance.getSupportedSerdes();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SerdesRelatedOperationsApi#getSupportedSerdes");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.SerdesRelatedOperationsApi;

public class SerdesRelatedOperationsApiExample {

    public static void main(String[] args) {
        SerdesRelatedOperationsApi apiInstance = new SerdesRelatedOperationsApi();
        try {
            SerdesMappings result = apiInstance.getSupportedSerdes();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling SerdesRelatedOperationsApi#getSupportedSerdes");
            e.printStackTrace();
        }
    }
}

SerdesRelatedOperationsApi *apiInstance = [[SerdesRelatedOperationsApi alloc] init];

// List of supported serdes
[apiInstance getSupportedSerdesWithCompletionHandler: 
              ^(SerdesMappings output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.SerdesRelatedOperationsApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getSupportedSerdes(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getSupportedSerdesExample
    {
        public void main()
        {

            var apiInstance = new SerdesRelatedOperationsApi();

            try
            {
                // List of supported serdes
                SerdesMappings result = apiInstance.getSupportedSerdes();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling SerdesRelatedOperationsApi.getSupportedSerdes: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiSerdesRelatedOperationsApi();

try {
    $result = $api_instance->getSupportedSerdes();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling SerdesRelatedOperationsApi->getSupportedSerdes: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::SerdesRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::SerdesRelatedOperationsApi->new();

eval { 
    my $result = $api_instance->getSupportedSerdes();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling SerdesRelatedOperationsApi->getSupportedSerdes: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.SerdesRelatedOperationsApi()

try: 
    # List of supported serdes
    api_response = api_instance.get_supported_serdes()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling SerdesRelatedOperationsApi->getSupportedSerdes: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicConsumptionOperationsApi;

import java.io.File;
import java.util.*;

public class TopicConsumptionOperationsApiExample {

    public static void main(String[] args) {
        
        TopicConsumptionOperationsApi apiInstance = new TopicConsumptionOperationsApi();
        String topicName = topicName_example; // String | 
        Integer partitionId = 56; // Integer | 
        Long startOffset = 789; // Long | 
        Long endOffset = 789; // Long | 
        String keyDeserializer = keyDeserializer_example; // String | 
        String valueDeserializer = valueDeserializer_example; // String | 
        Long responseWaitTimeInMs = 789; // Long | 
        try {
            TopicContent result = apiInstance.getTopicContent(topicName, partitionId, startOffset, endOffset, keyDeserializer, valueDeserializer, responseWaitTimeInMs);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicConsumptionOperationsApi#getTopicContent");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicConsumptionOperationsApi;

public class TopicConsumptionOperationsApiExample {

    public static void main(String[] args) {
        TopicConsumptionOperationsApi apiInstance = new TopicConsumptionOperationsApi();
        String topicName = topicName_example; // String | 
        Integer partitionId = 56; // Integer | 
        Long startOffset = 789; // Long | 
        Long endOffset = 789; // Long | 
        String keyDeserializer = keyDeserializer_example; // String | 
        String valueDeserializer = valueDeserializer_example; // String | 
        Long responseWaitTimeInMs = 789; // Long | 
        try {
            TopicContent result = apiInstance.getTopicContent(topicName, partitionId, startOffset, endOffset, keyDeserializer, valueDeserializer, responseWaitTimeInMs);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicConsumptionOperationsApi#getTopicContent");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 
Integer *partitionId = 56; // 
Long *startOffset = 789; //  (optional)
Long *endOffset = 789; //  (optional)
String *keyDeserializer = keyDeserializer_example; //  (optional)
String *valueDeserializer = valueDeserializer_example; //  (optional)
Long *responseWaitTimeInMs = 789; //  (optional)

TopicConsumptionOperationsApi *apiInstance = [[TopicConsumptionOperationsApi alloc] init];

// Get topic content for a given topic, its partition and the offset range with in the partition
[apiInstance getTopicContentWith:topicName
    partitionId:partitionId
    startOffset:startOffset
    endOffset:endOffset
    keyDeserializer:keyDeserializer
    valueDeserializer:valueDeserializer
    responseWaitTimeInMs:responseWaitTimeInMs
              completionHandler: ^(TopicContent output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicConsumptionOperationsApi()
var topicName = topicName_example; // {{String}} 
var partitionId = 56; // {{Integer}} 
var opts = { 
  'startOffset': 789, // {{Long}} 
  'endOffset': 789, // {{Long}} 
  'keyDeserializer': keyDeserializer_example, // {{String}} 
  'valueDeserializer': valueDeserializer_example, // {{String}} 
  'responseWaitTimeInMs': 789 // {{Long}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicContent(topicName, partitionId, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicContentExample
    {
        public void main()
        {

            var apiInstance = new TopicConsumptionOperationsApi();
            var topicName = topicName_example;  // String | 
            var partitionId = 56;  // Integer | 
            var startOffset = 789;  // Long |  (optional) 
            var endOffset = 789;  // Long |  (optional) 
            var keyDeserializer = keyDeserializer_example;  // String |  (optional) 
            var valueDeserializer = valueDeserializer_example;  // String |  (optional) 
            var responseWaitTimeInMs = 789;  // Long |  (optional) 

            try
            {
                // Get topic content for a given topic, its partition and the offset range with in the partition
                TopicContent result = apiInstance.getTopicContent(topicName, partitionId, startOffset, endOffset, keyDeserializer, valueDeserializer, responseWaitTimeInMs);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicConsumptionOperationsApi.getTopicContent: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicConsumptionOperationsApi();
$topicName = topicName_example; // String | 
$partitionId = 56; // Integer | 
$startOffset = 789; // Long | 
$endOffset = 789; // Long | 
$keyDeserializer = keyDeserializer_example; // String | 
$valueDeserializer = valueDeserializer_example; // String | 
$responseWaitTimeInMs = 789; // Long | 

try {
    $result = $api_instance->getTopicContent($topicName, $partitionId, $startOffset, $endOffset, $keyDeserializer, $valueDeserializer, $responseWaitTimeInMs);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicConsumptionOperationsApi->getTopicContent: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicConsumptionOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicConsumptionOperationsApi->new();
my $topicName = topicName_example; # String | 
my $partitionId = 56; # Integer | 
my $startOffset = 789; # Long | 
my $endOffset = 789; # Long | 
my $keyDeserializer = keyDeserializer_example; # String | 
my $valueDeserializer = valueDeserializer_example; # String | 
my $responseWaitTimeInMs = 789; # Long | 

eval { 
    my $result = $api_instance->getTopicContent(topicName => $topicName, partitionId => $partitionId, startOffset => $startOffset, endOffset => $endOffset, keyDeserializer => $keyDeserializer, valueDeserializer => $valueDeserializer, responseWaitTimeInMs => $responseWaitTimeInMs);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicConsumptionOperationsApi->getTopicContent: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicConsumptionOperationsApi()
topicName = topicName_example # String | 
partitionId = 56 # Integer | 
startOffset = 789 # Long |  (optional)
endOffset = 789 # Long |  (optional)
keyDeserializer = keyDeserializer_example # String |  (optional)
valueDeserializer = valueDeserializer_example # String |  (optional)
responseWaitTimeInMs = 789 # Long |  (optional)

try: 
    # Get topic content for a given topic, its partition and the offset range with in the partition
    api_response = api_instance.get_topic_content(topicName, partitionId, startOffset=startOffset, endOffset=endOffset, keyDeserializer=keyDeserializer, valueDeserializer=valueDeserializer, responseWaitTimeInMs=responseWaitTimeInMs)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicConsumptionOperationsApi->getTopicContent: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicConsumptionOperationsApi;

import java.io.File;
import java.util.*;

public class TopicConsumptionOperationsApiExample {

    public static void main(String[] args) {
        
        TopicConsumptionOperationsApi apiInstance = new TopicConsumptionOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            TopicOffsetInfo result = apiInstance.getTopicOffsets(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicConsumptionOperationsApi#getTopicOffsets");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicConsumptionOperationsApi;

public class TopicConsumptionOperationsApiExample {

    public static void main(String[] args) {
        TopicConsumptionOperationsApi apiInstance = new TopicConsumptionOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            TopicOffsetInfo result = apiInstance.getTopicOffsets(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicConsumptionOperationsApi#getTopicOffsets");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

TopicConsumptionOperationsApi *apiInstance = [[TopicConsumptionOperationsApi alloc] init];

// Get offsets for all the partition for a given kafka topic name
[apiInstance getTopicOffsetsWith:topicName
              completionHandler: ^(TopicOffsetInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicConsumptionOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicOffsets(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicOffsetsExample
    {
        public void main()
        {

            var apiInstance = new TopicConsumptionOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Get offsets for all the partition for a given kafka topic name
                TopicOffsetInfo result = apiInstance.getTopicOffsets(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicConsumptionOperationsApi.getTopicOffsets: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicConsumptionOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getTopicOffsets($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicConsumptionOperationsApi->getTopicOffsets: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicConsumptionOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicConsumptionOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getTopicOffsets(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicConsumptionOperationsApi->getTopicOffsets: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicConsumptionOperationsApi()
topicName = topicName_example # String | 

try: 
    # Get offsets for all the partition for a given kafka topic name
    api_response = api_instance.get_topic_offsets(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicConsumptionOperationsApi->getTopicOffsets: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        try {
            array[TopicInfo] result = apiInstance.allTopicInfos();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#allTopicInfos");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        try {
            array[TopicInfo] result = apiInstance.allTopicInfos();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#allTopicInfos");
            e.printStackTrace();
        }
    }
}

TopicMetadataRelatedOperationsApi *apiInstance = [[TopicMetadataRelatedOperationsApi alloc] init];

// Get respective details for all the topics. 
[apiInstance allTopicInfosWithCompletionHandler: 
              ^(array[TopicInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetadataRelatedOperationsApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.allTopicInfos(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class allTopicInfosExample
    {
        public void main()
        {

            var apiInstance = new TopicMetadataRelatedOperationsApi();

            try
            {
                // Get respective details for all the topics. 
                array[TopicInfo] result = apiInstance.allTopicInfos();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetadataRelatedOperationsApi.allTopicInfos: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetadataRelatedOperationsApi();

try {
    $result = $api_instance->allTopicInfos();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetadataRelatedOperationsApi->allTopicInfos: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetadataRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetadataRelatedOperationsApi->new();

eval { 
    my $result = $api_instance->allTopicInfos();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicMetadataRelatedOperationsApi->allTopicInfos: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetadataRelatedOperationsApi()

try: 
    # Get respective details for all the topics. 
    api_response = api_instance.all_topic_infos()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicMetadataRelatedOperationsApi->allTopicInfos: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        NewPartitions body = ; // NewPartitions | 
        try {
            apiInstance.createPartitions(body);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#createPartitions");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        NewPartitions body = ; // NewPartitions | 
        try {
            apiInstance.createPartitions(body);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#createPartitions");
            e.printStackTrace();
        }
    }
}

NewPartitions *body = ; //  (optional)

TopicMetadataRelatedOperationsApi *apiInstance = [[TopicMetadataRelatedOperationsApi alloc] init];

// Alter topic partitions
[apiInstance createPartitionsWith:body
              completionHandler: ^(NSError* error) {
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetadataRelatedOperationsApi()
var opts = { 
  'body':  // {{NewPartitions}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully.');
  }
};
api.createPartitions(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class createPartitionsExample
    {
        public void main()
        {

            var apiInstance = new TopicMetadataRelatedOperationsApi();
            var body = new NewPartitions(); // NewPartitions |  (optional) 

            try
            {
                // Alter topic partitions
                apiInstance.createPartitions(body);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetadataRelatedOperationsApi.createPartitions: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetadataRelatedOperationsApi();
$body = ; // NewPartitions | 

try {
    $api_instance->createPartitions($body);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetadataRelatedOperationsApi->createPartitions: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetadataRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetadataRelatedOperationsApi->new();
my $body = WWW::SwaggerClient::Object::NewPartitions->new(); # NewPartitions | 

eval { 
    $api_instance->createPartitions(body => $body);
};
if ($@) {
    warn "Exception when calling TopicMetadataRelatedOperationsApi->createPartitions: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetadataRelatedOperationsApi()
body =  # NewPartitions |  (optional)

try: 
    # Alter topic partitions
    api_instance.create_partitions(body=body)
except ApiException as e:
    print("Exception when calling TopicMetadataRelatedOperationsApi->createPartitions: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        NewTopics body = ; // NewTopics | 
        try {
            apiInstance.createTopics(body);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#createTopics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        NewTopics body = ; // NewTopics | 
        try {
            apiInstance.createTopics(body);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#createTopics");
            e.printStackTrace();
        }
    }
}

NewTopics *body = ; //  (optional)

TopicMetadataRelatedOperationsApi *apiInstance = [[TopicMetadataRelatedOperationsApi alloc] init];

// Create topics
[apiInstance createTopicsWith:body
              completionHandler: ^(NSError* error) {
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetadataRelatedOperationsApi()
var opts = { 
  'body':  // {{NewTopics}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully.');
  }
};
api.createTopics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class createTopicsExample
    {
        public void main()
        {

            var apiInstance = new TopicMetadataRelatedOperationsApi();
            var body = new NewTopics(); // NewTopics |  (optional) 

            try
            {
                // Create topics
                apiInstance.createTopics(body);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetadataRelatedOperationsApi.createTopics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetadataRelatedOperationsApi();
$body = ; // NewTopics | 

try {
    $api_instance->createTopics($body);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetadataRelatedOperationsApi->createTopics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetadataRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetadataRelatedOperationsApi->new();
my $body = WWW::SwaggerClient::Object::NewTopics->new(); # NewTopics | 

eval { 
    $api_instance->createTopics(body => $body);
};
if ($@) {
    warn "Exception when calling TopicMetadataRelatedOperationsApi->createTopics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetadataRelatedOperationsApi()
body =  # NewTopics |  (optional)

try: 
    # Create topics
    api_instance.create_topics(body=body)
except ApiException as e:
    print("Exception when calling TopicMetadataRelatedOperationsApi->createTopics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        array[String] topicName = ; // array[String] | 
        try {
            apiInstance.deleteTopics(topicName);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#deleteTopics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        array[String] topicName = ; // array[String] | 
        try {
            apiInstance.deleteTopics(topicName);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#deleteTopics");
            e.printStackTrace();
        }
    }
}

array[String] *topicName = ; //  (optional)

TopicMetadataRelatedOperationsApi *apiInstance = [[TopicMetadataRelatedOperationsApi alloc] init];

// Delete topics
[apiInstance deleteTopicsWith:topicName
              completionHandler: ^(NSError* error) {
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetadataRelatedOperationsApi()
var opts = { 
  'topicName':  // {{array[String]}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully.');
  }
};
api.deleteTopics(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class deleteTopicsExample
    {
        public void main()
        {

            var apiInstance = new TopicMetadataRelatedOperationsApi();
            var topicName = new array[String](); // array[String] |  (optional) 

            try
            {
                // Delete topics
                apiInstance.deleteTopics(topicName);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetadataRelatedOperationsApi.deleteTopics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetadataRelatedOperationsApi();
$topicName = ; // array[String] | 

try {
    $api_instance->deleteTopics($topicName);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetadataRelatedOperationsApi->deleteTopics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetadataRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetadataRelatedOperationsApi->new();
my $topicName = []; # array[String] | 

eval { 
    $api_instance->deleteTopics(topicName => $topicName);
};
if ($@) {
    warn "Exception when calling TopicMetadataRelatedOperationsApi->deleteTopics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetadataRelatedOperationsApi()
topicName =  # array[String] |  (optional)

try: 
    # Delete topics
    api_instance.delete_topics(topicName=topicName)
except ApiException as e:
    print("Exception when calling TopicMetadataRelatedOperationsApi->deleteTopics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            TopicInfo result = apiInstance.getTopicInfo(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#getTopicInfo");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            TopicInfo result = apiInstance.getTopicInfo(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#getTopicInfo");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

TopicMetadataRelatedOperationsApi *apiInstance = [[TopicMetadataRelatedOperationsApi alloc] init];

// Get respective details about topic with the given `topicName`
[apiInstance getTopicInfoWith:topicName
              completionHandler: ^(TopicInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetadataRelatedOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicInfo(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicInfoExample
    {
        public void main()
        {

            var apiInstance = new TopicMetadataRelatedOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Get respective details about topic with the given `topicName`
                TopicInfo result = apiInstance.getTopicInfo(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetadataRelatedOperationsApi.getTopicInfo: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetadataRelatedOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getTopicInfo($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetadataRelatedOperationsApi->getTopicInfo: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetadataRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetadataRelatedOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getTopicInfo(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicMetadataRelatedOperationsApi->getTopicInfo: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetadataRelatedOperationsApi()
topicName = topicName_example # String | 

try: 
    # Get respective details about topic with the given `topicName`
    api_response = api_instance.get_topic_info(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicMetadataRelatedOperationsApi->getTopicInfo: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            array[TopicPartitionInfo] result = apiInstance.getTopicPartitions(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#getTopicPartitions");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetadataRelatedOperationsApi;

public class TopicMetadataRelatedOperationsApiExample {

    public static void main(String[] args) {
        TopicMetadataRelatedOperationsApi apiInstance = new TopicMetadataRelatedOperationsApi();
        String topicName = topicName_example; // String | 
        try {
            array[TopicPartitionInfo] result = apiInstance.getTopicPartitions(topicName);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetadataRelatedOperationsApi#getTopicPartitions");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // 

TopicMetadataRelatedOperationsApi *apiInstance = [[TopicMetadataRelatedOperationsApi alloc] init];

// Get respective partitions for the given topic with topicName
[apiInstance getTopicPartitionsWith:topicName
              completionHandler: ^(array[TopicPartitionInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetadataRelatedOperationsApi()
var topicName = topicName_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicPartitions(topicName, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicPartitionsExample
    {
        public void main()
        {

            var apiInstance = new TopicMetadataRelatedOperationsApi();
            var topicName = topicName_example;  // String | 

            try
            {
                // Get respective partitions for the given topic with topicName
                array[TopicPartitionInfo] result = apiInstance.getTopicPartitions(topicName);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetadataRelatedOperationsApi.getTopicPartitions: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetadataRelatedOperationsApi();
$topicName = topicName_example; // String | 

try {
    $result = $api_instance->getTopicPartitions($topicName);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetadataRelatedOperationsApi->getTopicPartitions: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetadataRelatedOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetadataRelatedOperationsApi->new();
my $topicName = topicName_example; # String | 

eval { 
    my $result = $api_instance->getTopicPartitions(topicName => $topicName);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicMetadataRelatedOperationsApi->getTopicPartitions: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetadataRelatedOperationsApi()
topicName = topicName_example # String | 

try: 
    # Get respective partitions for the given topic with topicName
    api_response = api_instance.get_topic_partitions(topicName)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicMetadataRelatedOperationsApi->getTopicPartitions: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetricsOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetricsOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetricsOperationsApi apiInstance = new TopicMetricsOperationsApi();
        String topicName = topicName_example; // String | Name of the topic
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            TopicMetrics result = apiInstance.getTopicMetrics(topicName, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetricsOperationsApi#getTopicMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetricsOperationsApi;

public class TopicMetricsOperationsApiExample {

    public static void main(String[] args) {
        TopicMetricsOperationsApi apiInstance = new TopicMetricsOperationsApi();
        String topicName = topicName_example; // String | Name of the topic
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            TopicMetrics result = apiInstance.getTopicMetrics(topicName, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetricsOperationsApi#getTopicMetrics");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // Name of the topic
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

TopicMetricsOperationsApi *apiInstance = [[TopicMetricsOperationsApi alloc] init];

// Get topic metrics for the given topic.
[apiInstance getTopicMetricsWith:topicName
    duration:duration
    from:from
    to:to
              completionHandler: ^(TopicMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetricsOperationsApi()
var topicName = topicName_example; // {{String}} Name of the topic
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicMetrics(topicName, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicMetricsExample
    {
        public void main()
        {

            var apiInstance = new TopicMetricsOperationsApi();
            var topicName = topicName_example;  // String | Name of the topic
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get topic metrics for the given topic.
                TopicMetrics result = apiInstance.getTopicMetrics(topicName, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetricsOperationsApi.getTopicMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetricsOperationsApi();
$topicName = topicName_example; // String | Name of the topic
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getTopicMetrics($topicName, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetricsOperationsApi->getTopicMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetricsOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetricsOperationsApi->new();
my $topicName = topicName_example; # String | Name of the topic
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getTopicMetrics(topicName => $topicName, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicMetricsOperationsApi->getTopicMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetricsOperationsApi()
topicName = topicName_example # String | Name of the topic
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get topic metrics for the given topic.
    api_response = api_instance.get_topic_metrics(topicName, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicMetricsOperationsApi->getTopicMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.TopicMetricsOperationsApi;

import java.io.File;
import java.util.*;

public class TopicMetricsOperationsApiExample {

    public static void main(String[] args) {
        
        TopicMetricsOperationsApi apiInstance = new TopicMetricsOperationsApi();
        String topicName = topicName_example; // String | Name of the topic
        Integer partitionNum = 56; // Integer | Partition number
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            TopicPartitionMetrics result = apiInstance.getTopicPartitionMetrics(topicName, partitionNum, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetricsOperationsApi#getTopicPartitionMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.TopicMetricsOperationsApi;

public class TopicMetricsOperationsApiExample {

    public static void main(String[] args) {
        TopicMetricsOperationsApi apiInstance = new TopicMetricsOperationsApi();
        String topicName = topicName_example; // String | Name of the topic
        Integer partitionNum = 56; // Integer | Partition number
        String duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
        Long from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
        Long to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value
        try {
            TopicPartitionMetrics result = apiInstance.getTopicPartitionMetrics(topicName, partitionNum, duration, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling TopicMetricsOperationsApi#getTopicPartitionMetrics");
            e.printStackTrace();
        }
    }
}

String *topicName = topicName_example; // Name of the topic
Integer *partitionNum = 56; // Partition number
String *duration = duration_example; // Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
Long *from = 789; // Beginning of the time period. Provide '-1' to fetch the latest value (optional)
Long *to = 789; // End of the time period. Provide '-1' to fetch the latest value (optional)

TopicMetricsOperationsApi *apiInstance = [[TopicMetricsOperationsApi alloc] init];

// Get topic-partition metrics for the given topic-partition.
[apiInstance getTopicPartitionMetricsWith:topicName
    partitionNum:partitionNum
    duration:duration
    from:from
    to:to
              completionHandler: ^(TopicPartitionMetrics output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.TopicMetricsOperationsApi()
var topicName = topicName_example; // {{String}} Name of the topic
var partitionNum = 56; // {{Integer}} Partition number
var opts = { 
  'duration': duration_example, // {{String}} Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
  'from': 789, // {{Long}} Beginning of the time period. Provide '-1' to fetch the latest value
  'to': 789 // {{Long}} End of the time period. Provide '-1' to fetch the latest value
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.getTopicPartitionMetrics(topicName, partitionNum, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class getTopicPartitionMetricsExample
    {
        public void main()
        {

            var apiInstance = new TopicMetricsOperationsApi();
            var topicName = topicName_example;  // String | Name of the topic
            var partitionNum = 56;  // Integer | Partition number
            var duration = duration_example;  // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional) 
            var from = 789;  // Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional) 
            var to = 789;  // Long | End of the time period. Provide '-1' to fetch the latest value (optional) 

            try
            {
                // Get topic-partition metrics for the given topic-partition.
                TopicPartitionMetrics result = apiInstance.getTopicPartitionMetrics(topicName, partitionNum, duration, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling TopicMetricsOperationsApi.getTopicPartitionMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiTopicMetricsOperationsApi();
$topicName = topicName_example; // String | Name of the topic
$partitionNum = 56; // Integer | Partition number
$duration = duration_example; // String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
$from = 789; // Long | Beginning of the time period. Provide '-1' to fetch the latest value
$to = 789; // Long | End of the time period. Provide '-1' to fetch the latest value

try {
    $result = $api_instance->getTopicPartitionMetrics($topicName, $partitionNum, $duration, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling TopicMetricsOperationsApi->getTopicPartitionMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::TopicMetricsOperationsApi;

my $api_instance = WWW::SwaggerClient::TopicMetricsOperationsApi->new();
my $topicName = topicName_example; # String | Name of the topic
my $partitionNum = 56; # Integer | Partition number
my $duration = duration_example; # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params
my $from = 789; # Long | Beginning of the time period. Provide '-1' to fetch the latest value
my $to = 789; # Long | End of the time period. Provide '-1' to fetch the latest value

eval { 
    my $result = $api_instance->getTopicPartitionMetrics(topicName => $topicName, partitionNum => $partitionNum, duration => $duration, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling TopicMetricsOperationsApi->getTopicPartitionMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.TopicMetricsOperationsApi()
topicName = topicName_example # String | Name of the topic
partitionNum = 56 # Integer | Partition number
duration = duration_example # String | Pre-defined Time duration. Supply either 'duration' [OR] 'from' & 'to' params (optional)
from = 789 # Long | Beginning of the time period. Provide '-1' to fetch the latest value (optional)
to = 789 # Long | End of the time period. Provide '-1' to fetch the latest value (optional)

try: 
    # Get topic-partition metrics for the given topic-partition.
    api_response = api_instance.get_topic_partition_metrics(topicName, partitionNum, duration=duration, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling TopicMetricsOperationsApi->getTopicPartitionMetrics: %s\n" % e)