ApiResponse<Version> |
AzkarraVersionApi.getCurrentVersionWithHttpInfo() |
get the API current version
|
ApiResponse<Map<String,Object>> |
AzkarraV1Api.getStreamsInstanceConfigWithHttpInfo(String containerId) |
get the configuration of the KafkaStreams instance
|
ApiResponse<V1StreamsConsumerGroupOffsets> |
AzkarraV1Api.getStreamsInstanceConsumerOffsetsWithHttpInfo(String containerId) |
get the offset posititions for the consumers of the Kafka Streams instance
|
ApiResponse<V1StreamsDetails> |
AzkarraV1Api.getStreamsInstanceDetailsWithHttpInfo(String containerId) |
get details about a Kafka Streams instance
|
ApiResponse<V1StreamsMetadata> |
AzkarraV1Api.getStreamsInstanceMetadataWithHttpInfo(String containerId) |
list the KafkaStreams instances currently active on the local Azkarra application
|
ApiResponse<V1MetricGroup> |
AzkarraV1Api.getStreamsInstanceMetricByGroupAndNameWithHttpInfo(String containerId,
String group,
String name) |
get the current metric for the streams instance, metric group and name
|
ApiResponse<List<V1MetricGroup>> |
AzkarraV1Api.getStreamsInstanceMetricsByGroupWithHttpInfo(String containerId,
String group) |
get the metrics for the Kafka Streams instance
|
ApiResponse<List<V1MetricGroup>> |
AzkarraV1Api.getStreamsInstanceMetricsWithHttpInfo(String containerId) |
get the metrics for the Kafka Streams instance
|
ApiResponse<String> |
AzkarraV1Api.getStreamsInstanceMetricValueWithHttpInfo(String containerId,
String group,
String name) |
get the current metric value for the streams application, metric group and name
|
ApiResponse<V1StreamsStatus> |
AzkarraV1Api.getStreamsInstanceStatusWithHttpInfo(String containerId) |
get the status about the running tasks of the KafkaStreams instance
|
ApiResponse<List<V1LocalStatePartitionsInfo>> |
AzkarraV1Api.getStreamsInstanceStoreOffsetsWithHttpInfo(String containerId) |
gets the partition lag and restoration info for all local state store
|
ApiResponse<V1StreamsTopology> |
AzkarraV1Api.getStreamsInstanceTopologyWithHttpInfo(String containerId) |
get the topology graph of the Kafka Streams instance
|
ApiResponse<List<String>> |
AzkarraV1Api.listKafkaStreamsApplicationIdsWithHttpInfo() |
list all ids for the Kafka Streams applications for which at least one instance is currently running.
|
ApiResponse<List<String>> |
AzkarraV1Api.listStreamsInstanceIdsWithHttpInfo() |
list the KafkaStreams instances currently active on the local Azkarra application
|
ApiResponse<V1QueryResult> |
AzkarraV1Api.queryStateStoreWithHttpInfo(String applicationId,
String storeName,
V1Query v1Query) |
Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
|
ApiResponse<Void> |
AzkarraV1Api.restartStreamsInstanceWithHttpInfo(String containerId) |
restart a running KafkaStreams instance
|
ApiResponse<Void> |
AzkarraV1Api.stopStreamsInstanceWithHttpInfo(String containerId,
V1Options v1Options) |
stop a running KafkaStreams instance
|