Constant Field Values
Contents
io.streamthoughts.*
-
io.streamthoughts.azkarra.api.StreamsExecutionEnvironment<T extends StreamsExecutionEnvironment<T>> Modifier and Type Constant Field Value public static final String
ENVIRONMENT_DEFAULT_NAME
"default"
-
io.streamthoughts.azkarra.api.components.Ordered Modifier and Type Constant Field Value public static final int
HIGHEST_ORDER
-2147483648
public static final int
LOWEST_ORDER
2147483647
-
io.streamthoughts.azkarra.api.components.Restriction Modifier and Type Constant Field Value public static final String
TYPE_APPLICATION
"application"
public static final String
TYPE_ENVIRONMENT
"env"
public static final String
TYPE_STREAMS
"streams"
-
io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier<T> Modifier and Type Constant Field Value public static final String
NAMES_MEMBER
"names"
public static final String
TYPE_MEMBER
"type"
-
io.streamthoughts.azkarra.api.query.LocalExecutableQuery<K,V> Modifier and Type Constant Field Value public static final int
NO_LIMIT
-1
-
io.streamthoughts.azkarra.api.query.internal.QueryConstants Modifier and Type Constant Field Value public static final String
QUERY_PARAM_KEY
"key"
public static final String
QUERY_PARAM_KEY_FROM
"keyFrom"
public static final String
QUERY_PARAM_KEY_TO
"keyTo"
public static final String
QUERY_PARAM_TIME
"time"
public static final String
QUERY_PARAM_TIME_FROM
"timeFrom"
public static final String
QUERY_PARAM_TIME_TO
"timeTo"
-
io.streamthoughts.azkarra.client.openapi.models.V1Error Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_MESSAGE
"message"
-
io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_NAME
"name"
public static final String
SERIALIZED_NAME_PARTITION_LAG_INFOS
"partition_lag_infos"
public static final String
SERIALIZED_NAME_PARTITION_RESTORE_INFOS
"partition_restore_infos"
-
io.streamthoughts.azkarra.client.openapi.models.V1Metric Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_DESCRIPTION
"description"
public static final String
SERIALIZED_NAME_NAME
"name"
public static final String
SERIALIZED_NAME_TAGS
"tags"
public static final String
SERIALIZED_NAME_VALUE
"value"
-
io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_METRICS
"metrics"
public static final String
SERIALIZED_NAME_NAME
"name"
-
io.streamthoughts.azkarra.client.openapi.models.V1Options Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_CLEANUP
"cleanup"
-
io.streamthoughts.azkarra.client.openapi.models.V1Query Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_QUERY
"query"
public static final String
SERIALIZED_NAME_SET_OPTIONS
"set_options"
public static final String
SERIALIZED_NAME_TYPE
"type"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryAll Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ALL
"all"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryCount Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_COUNT
"count"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ERRORS
"errors"
public static final String
SERIALIZED_NAME_REMOTE
"remote"
public static final String
SERIALIZED_NAME_SERVER
"server"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_FETCH
"fetch"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_FETCH_ALL
"fetch_all"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_TIME_FROM
"timeFrom"
public static final String
SERIALIZED_NAME_TIME_TO
"timeTo"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_FETCH_KEY_RANGE
"fetch_key_range"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_KEY_FROM
"keyFrom"
public static final String
SERIALIZED_NAME_KEY_TO
"keyTo"
public static final String
SERIALIZED_NAME_TIME_FROM
"timeFrom"
public static final String
SERIALIZED_NAME_TIME_TO
"timeTo"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_KEY
"key"
public static final String
SERIALIZED_NAME_TIME
"time"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_FETCH_TIME_RANGE
"fetch_time_range"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_KEY
"key"
public static final String
SERIALIZED_NAME_TIME_FROM
"timeFrom"
public static final String
SERIALIZED_NAME_TIME_TO
"timeTo"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryGet Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_GET
"get"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_KEY
"key"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ERROR
"error"
public static final String
SERIALIZED_NAME_FAILURE
"failure"
public static final String
SERIALIZED_NAME_STORE
"store"
public static final String
SERIALIZED_NAME_SUCCESS
"success"
public static final String
SERIALIZED_NAME_TOTAL
"total"
public static final String
SERIALIZED_NAME_TYPE
"type"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ALL
"all"
public static final String
SERIALIZED_NAME_COUNT
"count"
public static final String
SERIALIZED_NAME_FETCH
"fetch"
public static final String
SERIALIZED_NAME_FETCH_ALL
"fetch_all"
public static final String
SERIALIZED_NAME_FETCH_KEY_RANGE
"fetch_key_range"
public static final String
SERIALIZED_NAME_FETCH_TIME_RANGE
"fetch_time_range"
public static final String
SERIALIZED_NAME_GET
"get"
public static final String
SERIALIZED_NAME_RANGE
"range"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_LIMIT
"limit"
public static final String
SERIALIZED_NAME_QUERY_TIMEOUT_MS
"query_timeout_ms"
public static final String
SERIALIZED_NAME_REMOTE_ACCESS_ALLOWED
"remote_access_allowed"
public static final String
SERIALIZED_NAME_RETRIES
"retries"
public static final String
SERIALIZED_NAME_RETRY_BACKOFF_MS
"retry_backoff_ms"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryRange Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_RANGE
"range"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_KEY_FROM
"keyFrom"
public static final String
SERIALIZED_NAME_KEY_TO
"keyTo"
-
io.streamthoughts.azkarra.client.openapi.models.V1QueryResult Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_RESULT
"result"
public static final String
SERIALIZED_NAME_SERVER
"server"
public static final String
SERIALIZED_NAME_STATUS
"status"
public static final String
SERIALIZED_NAME_TIMEOUT
"timeout"
public static final String
SERIALIZED_NAME_TOOK
"took"
-
io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_RECORDS
"records"
public static final String
SERIALIZED_NAME_REMOTE
"remote"
public static final String
SERIALIZED_NAME_SERVER
"server"
public static final String
SERIALIZED_NAME_TOTAL
"total"
-
io.streamthoughts.azkarra.client.openapi.models.V1Record Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_KEY
"key"
public static final String
SERIALIZED_NAME_VALUE
"value"
-
io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_CURRENT_OFFSET
"current_offset"
public static final String
SERIALIZED_NAME_LOG_END_OFFSET
"log_end_offset"
public static final String
SERIALIZED_NAME_OFFSET_LAG
"offset_lag"
public static final String
SERIALIZED_NAME_PARTITION
"partition"
-
io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_DURATION
"duration"
public static final String
SERIALIZED_NAME_ENDING_OFFSET
"ending_offset"
public static final String
SERIALIZED_NAME_PARTITION
"partition"
public static final String
SERIALIZED_NAME_STARTING_OFFSET
"starting_offset"
public static final String
SERIALIZED_NAME_TOPIC
"topic"
public static final String
SERIALIZED_NAME_TOTAL_RESTORED
"total_restored"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_CLIENT_ID
"client_id"
public static final String
SERIALIZED_NAME_POSITIONS
"positions"
public static final String
SERIALIZED_NAME_STREAM_THREAD
"stream_thread"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_CONSUMERS
"consumers"
public static final String
SERIALIZED_NAME_GROUP
"group"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_COMMITTED_OFFSET
"committed_offset"
public static final String
SERIALIZED_NAME_COMMITTED_TIMESTAMP
"committed_timestamp"
public static final String
SERIALIZED_NAME_CONSUMED_OFFSET
"consumed_offset"
public static final String
SERIALIZED_NAME_CONSUMED_TIMESTAMP
"consumed_timestamp"
public static final String
SERIALIZED_NAME_LAG
"lag"
public static final String
SERIALIZED_NAME_LONG_END_OFFSET
"long_end_offset"
public static final String
SERIALIZED_NAME_LONG_START_COLON_OFFSET
"long_start:offset"
public static final String
SERIALIZED_NAME_TOPIC_PARTITION
"topic_partition"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_DESCRIPTION
"description"
public static final String
SERIALIZED_NAME_EXCEPTION
"exception"
public static final String
SERIALIZED_NAME_ID
"id"
public static final String
SERIALIZED_NAME_NAME
"name"
public static final String
SERIALIZED_NAME_SINCE
"since"
public static final String
SERIALIZED_NAME_STATE
"state"
public static final String
SERIALIZED_NAME_VERSION
"version"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ID
"id"
public static final String
SERIALIZED_NAME_PROCESSOR
"processor"
public static final String
SERIALIZED_NAME_SOURCE
"source"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ASSIGNMENTS
"assignments"
public static final String
SERIALIZED_NAME_STANDBY_ASSIGNMENTS
"standby_assignments"
public static final String
SERIALIZED_NAME_STANDBY_STATE_STORES
"standby_state_stores"
public static final String
SERIALIZED_NAME_STATE_STORES
"state_stores"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsState Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_SINCE
"since"
public static final String
SERIALIZED_NAME_STATE
"state"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ID
"id"
public static final String
SERIALIZED_NAME_STATE
"state"
public static final String
SERIALIZED_NAME_THREADS
"threads"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ID
"id"
public static final String
SERIALIZED_NAME_NODES
"nodes"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_GLOBAL_STORES
"globalStores"
public static final String
SERIALIZED_NAME_SUB_TOPOLOGIES
"subTopologies"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_NAME
"name"
public static final String
SERIALIZED_NAME_TYPE
"type"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_PREDECESSORS
"predecessors"
public static final String
SERIALIZED_NAME_STORES
"stores"
public static final String
SERIALIZED_NAME_SUCCESSORS
"successors"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_PREDECESSORS
"predecessors"
public static final String
SERIALIZED_NAME_STORES
"stores"
public static final String
SERIALIZED_NAME_SUCCESSORS
"successors"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_PREDECESSORS
"predecessors"
public static final String
SERIALIZED_NAME_TOPIC
"topic"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_PREDECESSORS
"predecessors"
public static final String
SERIALIZED_NAME_TOPIC
"topic"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_SUCCESSORS
"successors"
public static final String
SERIALIZED_NAME_TOPICS
"topics"
-
io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_SUCCESSORS
"successors"
public static final String
SERIALIZED_NAME_TOPICS
"topics"
-
io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_TASK_ID
"task_id"
public static final String
SERIALIZED_NAME_TOPIC_PARTITIONS
"topic_partitions"
-
io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_ACTIVE_TASKS
"active_tasks"
public static final String
SERIALIZED_NAME_ADMIN_CLIENT_ID
"admin_client_id"
public static final String
SERIALIZED_NAME_MAIN_CONSUMER_CLIENT_ID
"main_consumer_client_id"
public static final String
SERIALIZED_NAME_PRODUCER_CLIENT_IDS
"producer_client_ids"
public static final String
SERIALIZED_NAME_RESTORE_CONSUMER_CLIENT_ID
"restore_consumer_client_id"
public static final String
SERIALIZED_NAME_STANDBY_TASKS
"standby_tasks"
public static final String
SERIALIZED_NAME_THREAD_NAME
"thread_name"
public static final String
SERIALIZED_NAME_THREAD_STATE
"thread_state"
-
io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_PARTITION
"partition"
public static final String
SERIALIZED_NAME_TOPIC
"topic"
-
io.streamthoughts.azkarra.client.openapi.models.Version Modifier and Type Constant Field Value public static final String
SERIALIZED_NAME_AZKARRA_VERSION
"azkarraVersion"
public static final String
SERIALIZED_NAME_BRANCH
"branch"
public static final String
SERIALIZED_NAME_COMMIT_ID
"commitId"
-
io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig Modifier and Type Constant Field Value public static final String
DEAD_LETTER_HEADERS_PREFIX
"exception.handler.dead.letter.headers."
public static final String
DEAD_LETTER_PRODUCER_CONFIG
"exception.handler.dead.letter.producer."
public static final String
DEAD_LETTER_TOPIC_CONFIG
"exception.handler.dead.letter.topic"
public static final String
DEAD_LETTER_TOPIC_DOC
"The output topic to write rejected records."
public static final String
FATAL_ERRORS_CONFIG
"exception.handler.dead.letter.fatal.errors"
public static final String
FATAL_ERRORS_DOC
"List of exception classes on which the handler must fail."
-
io.streamthoughts.azkarra.commons.error.ExceptionHeader Modifier and Type Constant Field Value public static final String
ERROR_APPLICATION_ID
"__errors.application.id"
public static final String
ERROR_EXCEPTION_CLASS_NAME
"__errors.exception.class.name"
public static final String
ERROR_EXCEPTION_MESSAGE
"__errors.exception.message"
public static final String
ERROR_EXCEPTION_STACKTRACE
"__errors.exception.stacktrace"
public static final String
ERROR_RECORD_OFFSET
"__errors.record.offset"
public static final String
ERROR_RECORD_PARTITION
"__errors.record.partition"
public static final String
ERROR_RECORD_TOPIC
"__errors.record.topic"
public static final String
ERROR_TIMESTAMP
"__errors.timestamp"
-
io.streamthoughts.azkarra.commons.error.SafeDeserializerConfig Modifier and Type Constant Field Value public static final String
SAFE_DESERIALIZER_DEFAULT_VALUE_CONFIG
"safe.deserializer.default.object"
public static final String
SAFE_DESERIALIZER_DEFAULT_VALUE_DOC
"The default object value to return when an input record cannot be de-serialized (default is null)"
-
io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter Modifier and Type Constant Field Value public static final long
ROCKSDB_BLOCK_CACHE_SIZE_DEFAULT
52428800L
-
io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetterConfig Modifier and Type Constant Field Value public static final String
ROCKSDB_BACKGROUND_THREADS_COMPACTION_POOL_CONFIG
"rocksdb.background.thread.compaction.pool"
public static final String
ROCKSDB_BACKGROUND_THREADS_FLUSH_POOL_CONFIG
"rocksdb.background.thread.flush.pool"
public static final String
ROCKSDB_BLOCK_CACHE_SIZE_CONFIG
"rocksdb.block.cache.size"
public static final String
ROCKSDB_COMPACTION_STYLE_CONFIG
"rocksdb.compaction.style"
public static final String
ROCKSDB_COMPRESSION_TYPE_CONFIG
"rocksdb.compression.type"
public static final String
ROCKSDB_FILES_OPEN_CONFIG
"rocksdb.files.open"
public static final String
ROCKSDB_LOG_DIR_CONFIG
"rocksdb.log.dir"
public static final String
ROCKSDB_LOG_LEVEL_CONFIG
"rocksdb.log.level"
public static final String
ROCKSDB_MAX_BACKGROUND_COMPACTIONS_CONFIG
"rocksdb.max.background.compactions"
public static final String
ROCKSDB_MAX_BACKGROUND_FLUSHES_CONFIG
"rocksdb.max.background.flushes"
public static final String
ROCKSDB_MAX_LOG_FILE_SIZE_CONFIG
"rocksdb.log.max.file.size"
public static final String
ROCKSDB_MAX_WRITE_BUFFER_NUMBER_CONFIG
"rocksdb.max.write.buffer.number"
public static final String
ROCKSDB_MEMORY_HIGH_PRIO_POOL_RATIO_CONFIG
"rocksdb.memory.high.prio.pool.ratio"
public static final double
ROCKSDB_MEMORY_HIGH_PRIO_POOL_RATIO_DEFAULT
0.1
public static final String
ROCKSDB_MEMORY_MANAGED_CONFIG
"rocksdb.memory.managed"
public static final String
ROCKSDB_MEMORY_MANAGED_DOC
"Enable automatic memory management across all RocksDB instances."
public static final String
ROCKSDB_MEMORY_STRICT_CAPACITY_LIMIT_CONFIG
"rocksdb.memory.strict.capacity.limit"
public static final String
ROCKSDB_MEMORY_WRITE_BUFFER_RATIO_CONFIG
"rocksdb.memory.write.buffer.ratio"
public static final double
ROCKSDB_MEMORY_WRITE_BUFFER_RATIO_DEFAULT
0.5
public static final String
ROCKSDB_STATS_DUMP_PERIOD_SEC_CONFIG
"rocksdb.stats.dump.period.sec"
public static final String
ROCKSDB_STATS_DUMP_PERIOD_SEC_DOC
"The RocksDB statistics dump period in seconds."
public static final String
ROCKSDB_STATS_ENABLE_CONFIG
"rocksdb.stats.enable"
public static final String
ROCKSDB_WRITE_BUFFER_SIZE_CONFIG
"rocksdb.write.buffer.size"
-
io.streamthoughts.azkarra.http.APIVersions Modifier and Type Constant Field Value public static final String
PATH_V1
"/api/v1"
-
io.streamthoughts.azkarra.http.ServerConfig Modifier and Type Constant Field Value public static final String
HTTP_SERVER_LISTENER_CONFIG
"listener"
public static final String
HTTP_SERVER_PORT_CONFIG
"port"
public static final int
HTTP_SERVER_PORT_DEFAULT
8080
public static final String
HTTP_SERVER_REST_EXTENSIONS_ENABLE
"rest.extensions.enable"
public static final String
HTTP_SERVER_WEB_UI_ENABLE_CONFIG
"webui.enable"
-
io.streamthoughts.azkarra.http.ServerConfigBuilder Modifier and Type Constant Field Value public static final String
HTTP_ENABLE_UI
"enable.ui"
public static final String
HTTP_LISTENER_LISTER_CONFIG
"listener"
public static final String
HTTP_PORT_CONFIG
"port"
public static final String
HTTP_REST_EXTENSIONS_ENABLE
"rest.extensions.enable"
-
io.streamthoughts.azkarra.http.routes.ApiContextRoutes Modifier and Type Constant Field Value public static final String
PATH
"/api/v1/context"
-
io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes Modifier and Type Constant Field Value public static final String
PATH_ENVIRONMENT_TYPES
"/api/v1/environment-types"
public static final String
PATH_ENVIRONMENTS
"/api/v1/environments"
-
io.streamthoughts.azkarra.http.security.SecurityConfig Modifier and Type Constant Field Value public static final String
HTTP_AUTH_PRINCIPAL_BUILDER_CLASS_CONFIG
"principal.builder.class"
public static final String
HTTP_AUTH_USER_IDENTITY_MANAGER_CLASS_CONFIG
"users.identity.manager.class"
public static final String
HTTP_AUTHORIZATION_MANAGER_CLASS_CONFIG
"authorization.manager.class"
public static final String
HTTP_HEADLESS_CONFIG
"headless"
public static final String
HTTP_RESTRICTED_ROLES_CONFIG
"auth.restricted.roles"
public static final String
REST_AUTHENTICATION_BASIC_SILENT_CONFIG
"rest.authentication.basic.silent"
public static final String
REST_AUTHENTICATION_MECHANISM_CONFIG
"rest.authentication.mechanism"
public static final String
REST_AUTHENTICATION_REALM_CONFIG
"rest.authentication.realm"
public static final String
REST_AUTHENTICATION_ROLES_CONFIG
"rest.authentication.roles"
public static final String
REST_AUTHENTICATION_USERS_CONFIG
"rest.authentication.users"
public static final String
SSL_ENABLE
"ssl.enable"
public static final String
SSL_IGNORE_HOSTNAME_VERIFICATION
"ssl.ignore.hostname.verification"
public static final String
SSL_KEY_PASSWORD_CONFIG
"ssl.key.password"
public static final String
SSL_KEYSTORE_LOCATION
"ssl.keystore.location"
public static final String
SSL_KEYSTORE_PASSWORD
"ssl.keystore.password"
public static final String
SSL_KEYSTORE_TYPE
"ssl.keystore.type"
public static final String
SSL_TRUSTSTORE_LOCATION
"ssl.truststore.location"
public static final String
SSL_TRUSTSTORE_PASSWORD
"ssl.truststore.password"
public static final String
SSL_TRUSTSTORE_TYPE
"ssl.truststore.type"
-
io.streamthoughts.azkarra.http.utils.Constants Modifier and Type Constant Field Value public static final String
HTTP_QUERY_PARAM_EVENT
"event"
public static final String
HTTP_QUERY_PARAM_FILTER_EMPTY
"filter_empty"
public static final String
HTTP_QUERY_PARAM_FORMAT
"format"
public static final String
HTTP_QUERY_PARAM_FORMAT_VALUE_PROMETHEUS
"prometheus"
public static final String
HTTP_QUERY_PARAM_GROUP
"group"
public static final String
HTTP_QUERY_PARAM_ID
"id"
public static final String
HTTP_QUERY_PARAM_METRIC
"metric"
public static final String
HTTP_QUERY_PARAM_STORE
"storeName"
public static final String
HTTP_QUERY_PARAM_TYPE
"type"
public static final String
HTTP_QUERY_PARAM_VERSION
"version"
-
io.streamthoughts.azkarra.metrics.AzkarraMetricsConfig Modifier and Type Constant Field Value public static final String
METRICS_BINDERS_JVM_ENABLE_CONFIG
"metrics.binders.jvm.enable"
public static final String
METRICS_BINDERS_KAFKA_STREAMS_ENABLE_CONFIG
"metrics.binders.kafkastreams.enable"
public static final String
METRICS_ENABLE_CONFIG
"metrics.enable"
public static final String
METRICS_ENDPOINT_PROMETHEUS_ENABLE_CONFIG
"metrics.endpoints.prometheus.enable"
-
io.streamthoughts.azkarra.metrics.AzkarraMetricsConfigEntryLoader Modifier and Type Constant Field Value public static final String
CONFIG_ENTRY_KEY
"metrics"
-
io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext Modifier and Type Constant Field Value public static final String
DEFAULT_ENV_NAME
"default"
-
io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment Modifier and Type Constant Field Value public static final String
STREAMS_CONFIG_PREFIX
"streams"
public static final String
TYPE
"local"
-
io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder Modifier and Type Constant Field Value public static final String
CONTAINER_ID_CONFIG
"container.id"
-
io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig Modifier and Type Constant Field Value public static final String
KAFKA_READY_INTERCEPTOR_ENABLE_CONFIG
"kafka.ready.interceptor.enable"
public static final String
KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_CONFIG
"kafka.ready.interceptor.min.available.brokers"
public static final int
KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_DEFAULT
1
public static final String
KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_CONFIG
"kafka.ready.interceptor.retry.backoff.ms"
public static final long
KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_DEFAULT
1000L
public static final String
KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_CONFIG
"kafka.ready.interceptor.timeout.ms"
public static final long
KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_DEFAULT
60000L
-
io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig Modifier and Type Constant Field Value public static final String
MONITORING_INTERCEPTOR_ADVERTISED_SERVER_CONFIG
"monitoring.streams.interceptor.advertised.server"
public static final String
MONITORING_INTERCEPTOR_ENABLE_STORES_LAG_CONFIG
"monitoring.streams.interceptor.info.enabled.stores.lag"
public static final String
MONITORING_INTERCEPTOR_EXTENSIONS_CONFIG
"monitoring.streams.interceptor.ce.extensions"
public static final String
MONITORING_INTERCEPTOR_INTERVAL_MS_CONFIG
"monitoring.streams.interceptor.interval.ms"
public static final long
MONITORING_INTERCEPTOR_INTERVAL_MS_DEFAULT
10000L
public static final String
MONITORING_INTERCEPTOR_PRODUCER_PREFIX
"monitoring.streams.interceptor.producer"
public static final String
MONITORING_INTERCEPTOR_REPORTERS_CLASSES_CONFIG
"monitoring.streams.interceptor.reporters"
public static final String
MONITORING_INTERCEPTOR_TOPIC_CONFIG
"monitoring.streams.interceptor.topic"
public static final String
MONITORING_INTERCEPTOR_TOPIC_DEFAULT
"_azkarra-streams-monitoring"
-
io.streamthoughts.azkarra.streams.AzkarraApplication Modifier and Type Constant Field Value public static final String
AZKARRA_ROOT_CONFIG_KEY
"azkarra"
-
io.streamthoughts.azkarra.streams.config.loader.AutoStartConfigEntryLoader Modifier and Type Constant Field Value public static final String
CONFIG_ENTRY_KEY
"autostart"
-
io.streamthoughts.azkarra.streams.config.loader.StreamsConfigEntryLoader Modifier and Type Constant Field Value public static final String
CONFIG_ENTRY_KEY
"streams"
-
io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig Modifier and Type Constant Field Value public static final String
ENVIRONMENT_CONFIG
"config"
public static final String
ENVIRONMENT_NAME_CONFIG
"name"
public static final String
ENVIRONMENT_STREAMS_CONFIG
"jobs"
public static final String
ENVIRONMENT_TYPE_CONFIG
"type"
-
io.streamthoughts.azkarra.streams.config.loader.internal.TopologyConfig Modifier and Type Constant Field Value public static final String
TOPOLOGY_DESCRIPTION_CONFIG
"description"
public static final String
TOPOLOGY_NAME_CONFIG
"name"
public static final String
TOPOLOGY_PROVIDER_ALIAS_CONFIG
"topology"
public static final String
TOPOLOGY_PROVIDER_VERSION_CONFIG
"version"
public static final String
TOPOLOGY_STREAMS_CONFIG
"config"