Version |
AzkarraVersionApi.getCurrentVersion() |
get the API current version
|
okhttp3.Call |
AzkarraVersionApi.getCurrentVersionAsync(ApiCallback<Version> _callback) |
(asynchronously)
get the API current version
|
okhttp3.Call |
AzkarraVersionApi.getCurrentVersionCall(ApiCallback _callback) |
Build call for getCurrentVersion
|
ApiResponse<Version> |
AzkarraVersionApi.getCurrentVersionWithHttpInfo() |
get the API current version
|
Map<String,Object> |
AzkarraV1Api.getStreamsInstanceConfig(String containerId) |
get the configuration of the KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceConfigAsync(String containerId,
ApiCallback<Map<String,Object>> _callback) |
(asynchronously)
get the configuration of the KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceConfigCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceConfig
|
ApiResponse<Map<String,Object>> |
AzkarraV1Api.getStreamsInstanceConfigWithHttpInfo(String containerId) |
get the configuration of the KafkaStreams instance
|
V1StreamsConsumerGroupOffsets |
AzkarraV1Api.getStreamsInstanceConsumerOffsets(String containerId) |
get the offset posititions for the consumers of the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceConsumerOffsetsAsync(String containerId,
ApiCallback<V1StreamsConsumerGroupOffsets> _callback) |
(asynchronously)
get the offset posititions for the consumers of the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceConsumerOffsetsCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceConsumerOffsets
|
ApiResponse<V1StreamsConsumerGroupOffsets> |
AzkarraV1Api.getStreamsInstanceConsumerOffsetsWithHttpInfo(String containerId) |
get the offset posititions for the consumers of the Kafka Streams instance
|
V1StreamsDetails |
AzkarraV1Api.getStreamsInstanceDetails(String containerId) |
get details about a Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceDetailsAsync(String containerId,
ApiCallback<V1StreamsDetails> _callback) |
(asynchronously)
get details about a Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceDetailsCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceDetails
|
ApiResponse<V1StreamsDetails> |
AzkarraV1Api.getStreamsInstanceDetailsWithHttpInfo(String containerId) |
get details about a Kafka Streams instance
|
V1StreamsMetadata |
AzkarraV1Api.getStreamsInstanceMetadata(String containerId) |
list the KafkaStreams instances currently active on the local Azkarra application
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetadataAsync(String containerId,
ApiCallback<V1StreamsMetadata> _callback) |
(asynchronously)
list the KafkaStreams instances currently active on the local Azkarra application
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetadataCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceMetadata
|
ApiResponse<V1StreamsMetadata> |
AzkarraV1Api.getStreamsInstanceMetadataWithHttpInfo(String containerId) |
list the KafkaStreams instances currently active on the local Azkarra application
|
V1MetricGroup |
AzkarraV1Api.getStreamsInstanceMetricByGroupAndName(String containerId,
String group,
String name) |
get the current metric for the streams instance, metric group and name
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricByGroupAndNameAsync(String containerId,
String group,
String name,
ApiCallback<V1MetricGroup> _callback) |
(asynchronously)
get the current metric for the streams instance, metric group and name
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricByGroupAndNameCall(String containerId,
String group,
String name,
ApiCallback _callback) |
Build call for getStreamsInstanceMetricByGroupAndName
|
ApiResponse<V1MetricGroup> |
AzkarraV1Api.getStreamsInstanceMetricByGroupAndNameWithHttpInfo(String containerId,
String group,
String name) |
get the current metric for the streams instance, metric group and name
|
List<V1MetricGroup> |
AzkarraV1Api.getStreamsInstanceMetrics(String containerId) |
get the metrics for the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricsAsync(String containerId,
ApiCallback<List<V1MetricGroup>> _callback) |
(asynchronously)
get the metrics for the Kafka Streams instance
|
List<V1MetricGroup> |
AzkarraV1Api.getStreamsInstanceMetricsByGroup(String containerId,
String group) |
get the metrics for the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricsByGroupAsync(String containerId,
String group,
ApiCallback<List<V1MetricGroup>> _callback) |
(asynchronously)
get the metrics for the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricsByGroupCall(String containerId,
String group,
ApiCallback _callback) |
Build call for getStreamsInstanceMetricsByGroup
|
ApiResponse<List<V1MetricGroup>> |
AzkarraV1Api.getStreamsInstanceMetricsByGroupWithHttpInfo(String containerId,
String group) |
get the metrics for the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricsCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceMetrics
|
ApiResponse<List<V1MetricGroup>> |
AzkarraV1Api.getStreamsInstanceMetricsWithHttpInfo(String containerId) |
get the metrics for the Kafka Streams instance
|
String |
AzkarraV1Api.getStreamsInstanceMetricValue(String containerId,
String group,
String name) |
get the current metric value for the streams application, metric group and name
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricValueAsync(String containerId,
String group,
String name,
ApiCallback<String> _callback) |
(asynchronously)
get the current metric value for the streams application, metric group and name
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceMetricValueCall(String containerId,
String group,
String name,
ApiCallback _callback) |
Build call for getStreamsInstanceMetricValue
|
ApiResponse<String> |
AzkarraV1Api.getStreamsInstanceMetricValueWithHttpInfo(String containerId,
String group,
String name) |
get the current metric value for the streams application, metric group and name
|
V1StreamsStatus |
AzkarraV1Api.getStreamsInstanceStatus(String containerId) |
get the status about the running tasks of the KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceStatusAsync(String containerId,
ApiCallback<V1StreamsStatus> _callback) |
(asynchronously)
get the status about the running tasks of the KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceStatusCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceStatus
|
ApiResponse<V1StreamsStatus> |
AzkarraV1Api.getStreamsInstanceStatusWithHttpInfo(String containerId) |
get the status about the running tasks of the KafkaStreams instance
|
List<V1LocalStatePartitionsInfo> |
AzkarraV1Api.getStreamsInstanceStoreOffsets(String containerId) |
gets the partition lag and restoration info for all local state store
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceStoreOffsetsAsync(String containerId,
ApiCallback<List<V1LocalStatePartitionsInfo>> _callback) |
(asynchronously)
gets the partition lag and restoration info for all local state store
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceStoreOffsetsCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceStoreOffsets
|
ApiResponse<List<V1LocalStatePartitionsInfo>> |
AzkarraV1Api.getStreamsInstanceStoreOffsetsWithHttpInfo(String containerId) |
gets the partition lag and restoration info for all local state store
|
V1StreamsTopology |
AzkarraV1Api.getStreamsInstanceTopology(String containerId) |
get the topology graph of the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceTopologyAsync(String containerId,
ApiCallback<V1StreamsTopology> _callback) |
(asynchronously)
get the topology graph of the Kafka Streams instance
|
okhttp3.Call |
AzkarraV1Api.getStreamsInstanceTopologyCall(String containerId,
ApiCallback _callback) |
Build call for getStreamsInstanceTopology
|
ApiResponse<V1StreamsTopology> |
AzkarraV1Api.getStreamsInstanceTopologyWithHttpInfo(String containerId) |
get the topology graph of the Kafka Streams instance
|
List<String> |
AzkarraV1Api.listKafkaStreamsApplicationIds() |
list all ids for the Kafka Streams applications for which at least one instance is currently running.
|
okhttp3.Call |
AzkarraV1Api.listKafkaStreamsApplicationIdsAsync(ApiCallback<List<String>> _callback) |
(asynchronously)
list all ids for the Kafka Streams applications for which at least one instance is currently running.
|
okhttp3.Call |
AzkarraV1Api.listKafkaStreamsApplicationIdsCall(ApiCallback _callback) |
Build call for listKafkaStreamsApplicationIds
|
ApiResponse<List<String>> |
AzkarraV1Api.listKafkaStreamsApplicationIdsWithHttpInfo() |
list all ids for the Kafka Streams applications for which at least one instance is currently running.
|
List<String> |
AzkarraV1Api.listStreamsInstanceIds() |
list the KafkaStreams instances currently active on the local Azkarra application
|
okhttp3.Call |
AzkarraV1Api.listStreamsInstanceIdsAsync(ApiCallback<List<String>> _callback) |
(asynchronously)
list the KafkaStreams instances currently active on the local Azkarra application
|
okhttp3.Call |
AzkarraV1Api.listStreamsInstanceIdsCall(ApiCallback _callback) |
Build call for listStreamsInstanceIds
|
ApiResponse<List<String>> |
AzkarraV1Api.listStreamsInstanceIdsWithHttpInfo() |
list the KafkaStreams instances currently active on the local Azkarra application
|
V1QueryResult |
AzkarraV1Api.queryStateStore(String applicationId,
String storeName,
V1Query v1Query) |
Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
|
okhttp3.Call |
AzkarraV1Api.queryStateStoreAsync(String applicationId,
String storeName,
V1Query v1Query,
ApiCallback<V1QueryResult> _callback) |
(asynchronously)
Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
|
okhttp3.Call |
AzkarraV1Api.queryStateStoreCall(String applicationId,
String storeName,
V1Query v1Query,
ApiCallback _callback) |
Build call for queryStateStore
|
ApiResponse<V1QueryResult> |
AzkarraV1Api.queryStateStoreWithHttpInfo(String applicationId,
String storeName,
V1Query v1Query) |
Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
|
void |
AzkarraV1Api.restartStreamsInstance(String containerId) |
restart a running KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.restartStreamsInstanceAsync(String containerId,
ApiCallback<Void> _callback) |
(asynchronously)
restart a running KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.restartStreamsInstanceCall(String containerId,
ApiCallback _callback) |
Build call for restartStreamsInstance
|
ApiResponse<Void> |
AzkarraV1Api.restartStreamsInstanceWithHttpInfo(String containerId) |
restart a running KafkaStreams instance
|
void |
AzkarraV1Api.stopStreamsInstance(String containerId,
V1Options v1Options) |
stop a running KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.stopStreamsInstanceAsync(String containerId,
V1Options v1Options,
ApiCallback<Void> _callback) |
(asynchronously)
stop a running KafkaStreams instance
|
okhttp3.Call |
AzkarraV1Api.stopStreamsInstanceCall(String containerId,
V1Options v1Options,
ApiCallback _callback) |
Build call for stopStreamsInstance
|
ApiResponse<Void> |
AzkarraV1Api.stopStreamsInstanceWithHttpInfo(String containerId,
V1Options v1Options) |
stop a running KafkaStreams instance
|