Package io.streamthoughts.azkarra.client.openapi.apis

Class AzkarraV1Api

  • public class AzkarraV1Api
extends Object

    • Constructor Detail

      • AzkarraV1Api

        public AzkarraV1Api()

      • AzkarraV1Api

        public AzkarraV1Api​(ApiClient apiClient)

    • Method Detail

      • getApiClient

        public ApiClient getApiClient()

      • setApiClient

        public void setApiClient​(ApiClient apiClient)

      • getStreamsInstanceConfigCall

        public okhttp3.Call getStreamsInstanceConfigCall​(String containerId,
                                                 ApiCallback _callback)
                                          throws ApiException
        Build call for getStreamsInstanceConfig
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'containerId.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceConfig

        public Map<String,​Object> getStreamsInstanceConfig​(String containerId)
                                                  throws ApiException
        get the configuration of the KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'containerId.id' (required)
        Returns:
        Map<String, Object>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceConfigWithHttpInfo

        public ApiResponse<Map<String,​Object>> getStreamsInstanceConfigWithHttpInfo​(String containerId)
                                                                           throws ApiException
        get the configuration of the KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'containerId.id' (required)
        Returns:
        ApiResponse<Map<String, Object>>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceConfigAsync

        public okhttp3.Call getStreamsInstanceConfigAsync​(String containerId,
                                                  ApiCallback<Map<String,​Object>> _callback)
                                           throws ApiException
        (asynchronously) get the configuration of the KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'containerId.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceConsumerOffsetsCall

        public okhttp3.Call getStreamsInstanceConsumerOffsetsCall​(String containerId,
                                                          ApiCallback _callback)
                                                   throws ApiException
        Build call for getStreamsInstanceConsumerOffsets
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceConsumerOffsets

        public V1StreamsConsumerGroupOffsets getStreamsInstanceConsumerOffsets​(String containerId)
                                                                throws ApiException
        get the offset posititions for the consumers of the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        V1StreamsConsumerGroupOffsets
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceConsumerOffsetsWithHttpInfo

        public ApiResponse<V1StreamsConsumerGroupOffsets> getStreamsInstanceConsumerOffsetsWithHttpInfo​(String containerId)
                                                                                         throws ApiException
        get the offset posititions for the consumers of the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<V1StreamsConsumerGroupOffsets>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceConsumerOffsetsAsync

        public okhttp3.Call getStreamsInstanceConsumerOffsetsAsync​(String containerId,
                                                           ApiCallback<V1StreamsConsumerGroupOffsets> _callback)
                                                    throws ApiException
        (asynchronously) get the offset posititions for the consumers of the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceDetailsCall

        public okhttp3.Call getStreamsInstanceDetailsCall​(String containerId,
                                                  ApiCallback _callback)
                                           throws ApiException
        Build call for getStreamsInstanceDetails
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceDetails

        public V1StreamsDetails getStreamsInstanceDetails​(String containerId)
                                           throws ApiException
        get details about a Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        V1StreamsDetails
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceDetailsWithHttpInfo

        public ApiResponse<V1StreamsDetails> getStreamsInstanceDetailsWithHttpInfo​(String containerId)
                                                                    throws ApiException
        get details about a Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<V1StreamsDetails>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceDetailsAsync

        public okhttp3.Call getStreamsInstanceDetailsAsync​(String containerId,
                                                   ApiCallback<V1StreamsDetails> _callback)
                                            throws ApiException
        (asynchronously) get details about a Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceMetadataCall

        public okhttp3.Call getStreamsInstanceMetadataCall​(String containerId,
                                                   ApiCallback _callback)
                                            throws ApiException
        Build call for getStreamsInstanceMetadata
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceMetadata

        public V1StreamsMetadata getStreamsInstanceMetadata​(String containerId)
                                             throws ApiException
        list the KafkaStreams instances currently active on the local Azkarra application
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        V1StreamsMetadata
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetadataWithHttpInfo

        public ApiResponse<V1StreamsMetadata> getStreamsInstanceMetadataWithHttpInfo​(String containerId)
                                                                      throws ApiException
        list the KafkaStreams instances currently active on the local Azkarra application
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<V1StreamsMetadata>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetadataAsync

        public okhttp3.Call getStreamsInstanceMetadataAsync​(String containerId,
                                                    ApiCallback<V1StreamsMetadata> _callback)
                                             throws ApiException
        (asynchronously) list the KafkaStreams instances currently active on the local Azkarra application
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceMetricByGroupAndNameCall

        public okhttp3.Call getStreamsInstanceMetricByGroupAndNameCall​(String containerId,
                                                               String group,
                                                               String name,
                                                               ApiCallback _callback)
                                                        throws ApiException
        Build call for getStreamsInstanceMetricByGroupAndName
        Parameters:
        containerId - identifier of the KafkaStreams application, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceMetricByGroupAndName

        public V1MetricGroup getStreamsInstanceMetricByGroupAndName​(String containerId,
                                                            String group,
                                                            String name)
                                                     throws ApiException
        get the current metric for the streams instance, metric group and name
        Parameters:
        containerId - identifier of the KafkaStreams application, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        Returns:
        V1MetricGroup
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricByGroupAndNameWithHttpInfo

        public ApiResponse<V1MetricGroup> getStreamsInstanceMetricByGroupAndNameWithHttpInfo​(String containerId,
                                                                                     String group,
                                                                                     String name)
                                                                              throws ApiException
        get the current metric for the streams instance, metric group and name
        Parameters:
        containerId - identifier of the KafkaStreams application, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        Returns:
        ApiResponse<V1MetricGroup>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricByGroupAndNameAsync

        public okhttp3.Call getStreamsInstanceMetricByGroupAndNameAsync​(String containerId,
                                                                String group,
                                                                String name,
                                                                ApiCallback<V1MetricGroup> _callback)
                                                         throws ApiException
        (asynchronously) get the current metric for the streams instance, metric group and name
        Parameters:
        containerId - identifier of the KafkaStreams application, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceMetricValueCall

        public okhttp3.Call getStreamsInstanceMetricValueCall​(String containerId,
                                                      String group,
                                                      String name,
                                                      ApiCallback _callback)
                                               throws ApiException
        Build call for getStreamsInstanceMetricValue
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceMetricValue

        public String getStreamsInstanceMetricValue​(String containerId,
                                            String group,
                                            String name)
                                     throws ApiException
        get the current metric value for the streams application, metric group and name
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        Returns:
        String
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricValueWithHttpInfo

        public ApiResponse<String> getStreamsInstanceMetricValueWithHttpInfo​(String containerId,
                                                                     String group,
                                                                     String name)
                                                              throws ApiException
        get the current metric value for the streams application, metric group and name
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        Returns:
        ApiResponse<String>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricValueAsync

        public okhttp3.Call getStreamsInstanceMetricValueAsync​(String containerId,
                                                       String group,
                                                       String name,
                                                       ApiCallback<String> _callback)
                                                throws ApiException
        (asynchronously) get the current metric value for the streams application, metric group and name
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        name - name of the metric (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceMetricsCall

        public okhttp3.Call getStreamsInstanceMetricsCall​(String containerId,
                                                  ApiCallback _callback)
                                           throws ApiException
        Build call for getStreamsInstanceMetrics
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceMetrics

        public List<V1MetricGroup> getStreamsInstanceMetrics​(String containerId)
                                              throws ApiException
        get the metrics for the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        List<V1MetricGroup>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricsWithHttpInfo

        public ApiResponse<List<V1MetricGroup>> getStreamsInstanceMetricsWithHttpInfo​(String containerId)
                                                                       throws ApiException
        get the metrics for the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<List<V1MetricGroup>>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricsAsync

        public okhttp3.Call getStreamsInstanceMetricsAsync​(String containerId,
                                                   ApiCallback<List<V1MetricGroup>> _callback)
                                            throws ApiException
        (asynchronously) get the metrics for the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceMetricsByGroupCall

        public okhttp3.Call getStreamsInstanceMetricsByGroupCall​(String containerId,
                                                         String group,
                                                         ApiCallback _callback)
                                                  throws ApiException
        Build call for getStreamsInstanceMetricsByGroup
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceMetricsByGroup

        public List<V1MetricGroup> getStreamsInstanceMetricsByGroup​(String containerId,
                                                            String group)
                                                     throws ApiException
        get the metrics for the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        Returns:
        List<V1MetricGroup>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricsByGroupWithHttpInfo

        public ApiResponse<List<V1MetricGroup>> getStreamsInstanceMetricsByGroupWithHttpInfo​(String containerId,
                                                                                     String group)
                                                                              throws ApiException
        get the metrics for the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        Returns:
        ApiResponse<List<V1MetricGroup>>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceMetricsByGroupAsync

        public okhttp3.Call getStreamsInstanceMetricsByGroupAsync​(String containerId,
                                                          String group,
                                                          ApiCallback<List<V1MetricGroup>> _callback)
                                                   throws ApiException
        (asynchronously) get the metrics for the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        group - name of the group (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceStatusCall

        public okhttp3.Call getStreamsInstanceStatusCall​(String containerId,
                                                 ApiCallback _callback)
                                          throws ApiException
        Build call for getStreamsInstanceStatus
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceStatus

        public V1StreamsStatus getStreamsInstanceStatus​(String containerId)
                                         throws ApiException
        get the status about the running tasks of the KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        V1StreamsStatus
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceStatusWithHttpInfo

        public ApiResponse<V1StreamsStatus> getStreamsInstanceStatusWithHttpInfo​(String containerId)
                                                                  throws ApiException
        get the status about the running tasks of the KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<V1StreamsStatus>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceStatusAsync

        public okhttp3.Call getStreamsInstanceStatusAsync​(String containerId,
                                                  ApiCallback<V1StreamsStatus> _callback)
                                           throws ApiException
        (asynchronously) get the status about the running tasks of the KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceStoreOffsetsCall

        public okhttp3.Call getStreamsInstanceStoreOffsetsCall​(String containerId,
                                                       ApiCallback _callback)
                                                throws ApiException
        Build call for getStreamsInstanceStoreOffsets
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceStoreOffsets

        public List<V1LocalStatePartitionsInfo> getStreamsInstanceStoreOffsets​(String containerId)
                                                                throws ApiException
        gets the partition lag and restoration info for all local state store
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        List<V1LocalStatePartitionsInfo>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceStoreOffsetsWithHttpInfo

        public ApiResponse<List<V1LocalStatePartitionsInfo>> getStreamsInstanceStoreOffsetsWithHttpInfo​(String containerId)
                                                                                         throws ApiException
        gets the partition lag and restoration info for all local state store
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<List<V1LocalStatePartitionsInfo>>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceStoreOffsetsAsync

        public okhttp3.Call getStreamsInstanceStoreOffsetsAsync​(String containerId,
                                                        ApiCallback<List<V1LocalStatePartitionsInfo>> _callback)
                                                 throws ApiException
        (asynchronously) gets the partition lag and restoration info for all local state store
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • getStreamsInstanceTopologyCall

        public okhttp3.Call getStreamsInstanceTopologyCall​(String containerId,
                                                   ApiCallback _callback)
                                            throws ApiException
        Build call for getStreamsInstanceTopology
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • getStreamsInstanceTopology

        public V1StreamsTopology getStreamsInstanceTopology​(String containerId)
                                             throws ApiException
        get the topology graph of the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        V1StreamsTopology
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceTopologyWithHttpInfo

        public ApiResponse<V1StreamsTopology> getStreamsInstanceTopologyWithHttpInfo​(String containerId)
                                                                      throws ApiException
        get the topology graph of the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<V1StreamsTopology>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • getStreamsInstanceTopologyAsync

        public okhttp3.Call getStreamsInstanceTopologyAsync​(String containerId,
                                                    ApiCallback<V1StreamsTopology> _callback)
                                             throws ApiException
        (asynchronously) get the topology graph of the Kafka Streams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • listKafkaStreamsApplicationIdsCall

        public okhttp3.Call listKafkaStreamsApplicationIdsCall​(ApiCallback _callback)
                                                throws ApiException
        Build call for listKafkaStreamsApplicationIds
        Parameters:
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • listKafkaStreamsApplicationIds

        public List<String> listKafkaStreamsApplicationIds()
                                            throws ApiException
        list all ids for the Kafka Streams applications for which at least one instance is currently running. application
        Returns:
        List<String>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • listKafkaStreamsApplicationIdsWithHttpInfo

        public ApiResponse<List<String>> listKafkaStreamsApplicationIdsWithHttpInfo()
                                                                     throws ApiException
        list all ids for the Kafka Streams applications for which at least one instance is currently running. application
        Returns:
        ApiResponse<List<String>>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • listKafkaStreamsApplicationIdsAsync

        public okhttp3.Call listKafkaStreamsApplicationIdsAsync​(ApiCallback<List<String>> _callback)
                                                 throws ApiException
        (asynchronously) list all ids for the Kafka Streams applications for which at least one instance is currently running. application
        Parameters:
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • listStreamsInstanceIdsCall

        public okhttp3.Call listStreamsInstanceIdsCall​(ApiCallback _callback)
                                        throws ApiException
        Build call for listStreamsInstanceIds
        Parameters:
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • listStreamsInstanceIds

        public List<String> listStreamsInstanceIds()
                                    throws ApiException
        list the KafkaStreams instances currently active on the local Azkarra application
        Returns:
        List<String>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • listStreamsInstanceIdsWithHttpInfo

        public ApiResponse<List<String>> listStreamsInstanceIdsWithHttpInfo()
                                                             throws ApiException
        list the KafkaStreams instances currently active on the local Azkarra application
        Returns:
        ApiResponse<List<String>>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • listStreamsInstanceIdsAsync

        public okhttp3.Call listStreamsInstanceIdsAsync​(ApiCallback<List<String>> _callback)
                                         throws ApiException
        (asynchronously) list the KafkaStreams instances currently active on the local Azkarra application
        Parameters:
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • queryStateStoreCall

        public okhttp3.Call queryStateStoreCall​(String applicationId,
                                        String storeName,
                                        V1Query v1Query,
                                        ApiCallback _callback)
                                 throws ApiException
        Build call for queryStateStore
        Parameters:
        applicationId - identifier of the KafkaStreams application, also known as the 'application.id' (required)
        storeName - name of the state store to query (required)
        v1Query - (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • queryStateStore

        public V1QueryResult queryStateStore​(String applicationId,
                                     String storeName,
                                     V1Query v1Query)
                              throws ApiException
        Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
        Parameters:
        applicationId - identifier of the KafkaStreams application, also known as the 'application.id' (required)
        storeName - name of the state store to query (required)
        v1Query - (required)
        Returns:
        V1QueryResult
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • queryStateStoreWithHttpInfo

        public ApiResponse<V1QueryResult> queryStateStoreWithHttpInfo​(String applicationId,
                                                              String storeName,
                                                              V1Query v1Query)
                                                       throws ApiException
        Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
        Parameters:
        applicationId - identifier of the KafkaStreams application, also known as the 'application.id' (required)
        storeName - name of the state store to query (required)
        v1Query - (required)
        Returns:
        ApiResponse<V1QueryResult>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • queryStateStoreAsync

        public okhttp3.Call queryStateStoreAsync​(String applicationId,
                                         String storeName,
                                         V1Query v1Query,
                                         ApiCallback<V1QueryResult> _callback)
                                  throws ApiException
        (asynchronously) Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
        Parameters:
        applicationId - identifier of the KafkaStreams application, also known as the 'application.id' (required)
        storeName - name of the state store to query (required)
        v1Query - (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • restartStreamsInstanceCall

        public okhttp3.Call restartStreamsInstanceCall​(String containerId,
                                               ApiCallback _callback)
                                        throws ApiException
        Build call for restartStreamsInstance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • restartStreamsInstance

        public void restartStreamsInstance​(String containerId)
                            throws ApiException
        restart a running KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • restartStreamsInstanceWithHttpInfo

        public ApiResponse<Void> restartStreamsInstanceWithHttpInfo​(String containerId)
                                                     throws ApiException
        restart a running KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        Returns:
        ApiResponse<Void>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • restartStreamsInstanceAsync

        public okhttp3.Call restartStreamsInstanceAsync​(String containerId,
                                                ApiCallback<Void> _callback)
                                         throws ApiException
        (asynchronously) restart a running KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object

      • stopStreamsInstanceCall

        public okhttp3.Call stopStreamsInstanceCall​(String containerId,
                                            V1Options v1Options,
                                            ApiCallback _callback)
                                     throws ApiException
        Build call for stopStreamsInstance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        v1Options - (required)
        _callback - Callback for upload/download progress
        Returns:
        Call to execute
        Throws:
        ApiException - If fail to serialize the request body object

      • stopStreamsInstance

        public void stopStreamsInstance​(String containerId,
                                V1Options v1Options)
                         throws ApiException
        stop a running KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        v1Options - (required)
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • stopStreamsInstanceWithHttpInfo

        public ApiResponse<Void> stopStreamsInstanceWithHttpInfo​(String containerId,
                                                         V1Options v1Options)
                                                  throws ApiException
        stop a running KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        v1Options - (required)
        Returns:
        ApiResponse<Void>
        Throws:
        ApiException - If fail to call the API, e.g. server error or cannot deserialize the response body

      • stopStreamsInstanceAsync

        public okhttp3.Call stopStreamsInstanceAsync​(String containerId,
                                             V1Options v1Options,
                                             ApiCallback<Void> _callback)
                                      throws ApiException
        (asynchronously) stop a running KafkaStreams instance
        Parameters:
        containerId - identifier of the KafkaStreams instance, also known as the 'container.id' (required)
        v1Options - (required)
        _callback - The callback to be executed when the API call finishes
        Returns:
        The request call
        Throws:
        ApiException - If fail to process the API call, e.g. serializing the request body object