All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
Class |
Description |
AbstractAuthentication<T extends Credentials> |
|
AbstractAzkarraStreamsService |
|
AbstractConf |
|
AbstractConfigEntryLoader |
|
AbstractResultSet |
|
AbstractStreamHttpHandler |
|
AbstractTopologyStreamsExecution<E extends StreamsExecutionEnvironment<E>> |
|
AdminClientUtils |
|
AllowAllHostNameVerifier |
|
AlreadyExistsException |
Thrown if an application or an environment already exists.
|
AnnotationResolver |
|
AnnotationResolver.AnnotationFilter |
|
AnnotationResolver.PackageAnnotationFilter |
|
AnnotationResolver.TypeAnnotationFilter |
|
AnyQualifier<T> |
|
ApiApplicationsRoutes |
This class defines all routes for API '/applications'.
|
ApiCallback<T> |
Callback for asynchronous API call.
|
ApiClient |
|
ApiContextRoutes |
|
ApiDefaultRoutes |
|
ApiDocHttpRoutes |
|
ApiEnvironmentRoutes |
|
ApiException |
|
ApiHealthRoutes |
|
ApiInfoRoutes |
|
ApiKeyAuth |
|
ApiOnFailureCallback |
|
ApiResponse<T> |
API response returned by API call.
|
ApiStreamsRoutes |
This class defines all routes for API '/streams'.
|
ApiTopologyRoutes |
This class defines all routes for API '/topologies'.
|
ApiVersionRoutes |
This class defines all routes for API '/version'.
|
APIVersions |
|
ApplicationConfigEntryLoader |
|
ApplicationConfigLoader |
|
ApplicationId |
An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.
|
ApplicationIdBuilder |
Class for building StreamsConfig.APPLICATION_ID_CONFIG .
|
ApplicationQueryStoreHandler |
|
ArgsConf |
A Conf which is build from a list of arguments.
|
AsyncMulticastEventStreamPublisher<K,V> |
The AsyncMulticastEventStreamPublisher is an implementation of Reactive Streams Flow.Publisher
which executes asynchronously, using an internal single-thread Executor .
|
AsyncQueryApiCallback<K,V> |
|
AtLeastOnce |
This annotation can be used to automatically set the streams property
processing.guarantee to at_least_once .
|
Authentication |
|
Authentication |
|
AuthenticationCallback<T extends Authentication> |
|
AuthenticationContext |
|
AuthenticationContextHandler |
|
AuthenticationContextHolder |
Class used to hold information about current authenticated principal.
|
AuthenticationManager |
|
Authenticator |
Interface to authenticate users.
|
AuthorizationContext |
|
AuthorizationHandler |
|
AuthorizationManager |
Pluggable interface which is used to authenticate users.
|
AuthorizationResult |
|
AutoConfigure |
|
AutoCreateTopicsInterceptor |
|
AutoCreateTopicsInterceptorConfig |
|
AutoStartConfigEntryLoader |
|
AzkarraAccount |
AzkarraAccount.
|
AzkarraApplication |
AzkarraApplication is the high-level class which can be used to deploy a simple server for managing multiple
KafkaStreams instances.
|
AzkarraBanner |
The default Banner implementation which writes "Kafka Streams".
|
AzkarraConf |
|
AzkarraContext |
The AzkarraContext.
|
AzkarraContextAware |
Interface to be implemented by any object that wishes to be notified of the AzkarraContext that it runs in.
|
AzkarraContextException |
|
AzkarraContextListener |
|
AzkarraException |
AzkarraException is the top-level error type generated by the core-api.
|
AzkarraExceptionMapper |
The default JAX-RS ExceptionMapper implementation.
|
AzkarraIdentityManager |
BasicMapIdentityManager.
|
AzkarraMetricsConfig |
Properties to configure metrics.
|
AzkarraMetricsConfigEntryLoader |
|
AzkarraPrincipalBuilder |
Pluggable builder interface which is used to build Principal object used during authorization.
|
AzkarraRestExtension |
A pluggable interface to allow registration of new JAX-RS resources like REST endpoints.
|
AzkarraRestExtensionContext |
This interfaces provides the capability for AzkarraRestExtension implementations
to register JAX-RS resources using the provided Configurable and to get access to
the AzkarraContext instance.
|
AzkarraRetriableException |
|
AzkarraRocksDBConfigSetter |
This RocksDBConfigSetter implementation allows fine-tuning of RocksDB instances.
|
AzkarraRocksDBConfigSetterConfig |
|
AzkarraSimpleModule |
A simple module with all registered serializers.
|
AzkarraStreamsApplication |
|
AzkarraStreamsService |
The AzkarraStreamsService serves as the main front-facing interface for manipulating streams applications.
|
AzkarraV1Api |
|
AzkarraVersion |
A AzkarraVersion is used to get version information about the running azkarra library.
|
AzkarraVersionApi |
|
AzkarraWorker |
The default main class for starting an Azkarra worker.
|
BadRequestException |
|
Banner |
|
Banner.Mode |
|
BannerPrinter |
|
BannerPrinterBuilder |
|
BaseAsyncQueryCall<K,V,Q extends Query> |
|
BaseComponentModule |
An abstract base class that can be extended to supply configurable components.
|
BaseKeyedLocalStoreQuery<K1,K2,V> |
|
BasicAuthAuthenticator |
BasicAuthAuthenticator.
|
BasicAuthAuthenticator.Credential |
|
BasicAuthenticationExample |
Example to configure an azkarra application with Basic authentication.
|
BasicAuthenticator |
BasicAuthenticator.
|
BasicBlockingRecordQueue<K,V> |
|
BasicComponentFactory<T> |
|
BasicContainerId |
|
BasicRolePrincipal |
|
BasicUserPrincipal |
BasicUserPrincipal.
|
BasicWordCountTopology |
A basic WordCount topology.
|
BlockingRecordQueue<K,V> |
A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.
|
CertClientAuthenticator |
|
CheckedFunction<T,R,E extends Exception> |
|
CheckedSupplier<R,E extends Throwable> |
|
ClassComponentAliasesGenerator |
|
ClassComponentAliasesGenerator.ClassAliasExtractor |
|
ClassComponentAliasesGenerator.DropClassNameSuffixExtractor |
|
ClassLoaderAwareKafkaStreamsFactory |
|
ClassloadingIsolationInterceptor |
|
ClassUtils |
|
CloseKafkaStreamsOnThreadException |
Closes immediately the KafkaStreams instance when a StreamThread
abruptly terminates due to an uncaught exception.
|
CloudEventsAttributes |
This class describes the required attributes for streams events, following CloudEvents
Specification.
|
CloudEventsBuilder<T> |
|
CloudEventsContext |
This class is used to wrap information about a Cloud Events
in the context of Kafka Streams.
|
CloudEventsEntity<T> |
|
CloudEventsExtension |
Represents a list of Cloud Events Extension.
|
ComplexWordCountTopology |
|
ComplexWordCountTopologyModule |
A ComponentModule for providing a new @{link ComplexWordCountTopology} instance.
|
Component |
Marker interface that any class having a no-arg constructor can used to indicate it can be registered.
|
ComponentAliasesGenerator |
|
ComponentAttribute |
|
ComponentClassLoader |
Default ClassLoader for loading components using a 'child-first strategy'.
|
ComponentConditionalContext<T extends ComponentDescriptor<?>> |
Interface to verify if a conditional component is enabled for a given context.
|
ComponentConfigEntryLoader |
|
ComponentDescriptor<T> |
|
ComponentDescriptorBuilder<T> |
|
ComponentDescriptorFactory |
|
ComponentDescriptorModifier |
Callback for modifying a given component descriptor.
|
ComponentDescriptorModifierResolver |
|
ComponentDescriptorModifierResolver.ApplyModifierOnAnnotationExist |
|
ComponentDescriptorModifierResolver.ApplyModifierOnAnnotations<T extends Annotation> |
|
ComponentDescriptorModifiers |
|
ComponentDescriptorRegistry |
|
ComponentFactory |
|
ComponentFactoryAware |
|
ComponentMetadata |
|
ComponentModule<T> |
|
ComponentNameGenerator |
Interface which is used for generating component name.
|
ComponentRegistrationException |
|
ComponentRegistry |
The ComponentRegistry is the main interface for managing components used in an Azkarra application.
|
ComponentResolver |
|
ComponentScan |
|
ComponentScanner |
|
CompositeQualifier<T> |
|
CompositeStateListener |
A KafkaStreams.StateListener that delegates to one or more KafkaStreams.StateListener in order.
|
CompositeStateRestoreListener |
A StateRestoreListener that delegates to one or more StateRestoreListener in order.
|
CompositeStreamsInterceptor |
|
CompositeUncaughtExceptionHandler |
|
Condition |
Define a single condition that need to be fulfilled for a component to be eligible for use in the application.
|
ConditionalDescriptorRegistry |
The main interface that defines methods to find registered ComponentDescriptor for
enable components.
|
ConditionalOn |
This annotation can be used to indicate the condition(s) that need to be fulfilled for a component to be eligible
for use in the application.
|
ConditionalOnMetricsEnable |
|
Conditionals |
This annotation can be used to indicate all the conditions that need to be fulfilled for a component to be eligible
for use in the application.
|
ConditionalStreamsApplication |
This example demonstrates how conditional components can be used to dynamically
change the behavior of a stream topology based on its configuration.
|
ConditionalStreamsApplication.Normalize |
|
ConditionalStreamsApplication.Normalizes |
|
ConditionalStreamsApplication.NormalizeStreamsTopology |
|
ConditionContext<T extends ComponentDescriptor> |
|
Conditions |
|
Conf |
A Conf represents an immutable object which can be used for configuring components.
|
ConfEntry |
|
ConfException |
ConfException is the top-level error type generated by the Conf api.
|
ConfigConditionalContext<T> |
|
Configurable |
|
ConfigurableComponentFactory |
|
ConfigurableStopWordsService |
|
ConfigurableSupplier<T> |
A configurable supplier.
|
ConfigurableWordCountTopology |
A basic WordCount topology.
|
Configuration |
|
ConflictingComponentDefinitionException |
|
ConfSerializer |
Json serializer for Conf .
|
ConfValue |
This annotation can be used to provide default config values to a configurable component.
|
ConfValues |
This annotation can be used to provide default config values to a configurable component.
|
Constants |
Helpers class for HTTP query params.
|
ConsumerClientOffsets |
|
ConsumerGroupOffsets |
|
ConsumerGroupOffsetsRegistry |
|
ConsumerGroupOffsetsState |
|
ConsumerLogOffsets |
|
ConsumerThreadKey |
|
ContainerId |
An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.
|
ContainerIdBuilder |
|
ContextAwareApplicationIdBuilderSupplier |
|
ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder |
|
ContextAwareComponentFactory |
|
ContextAwareComponentSupplier<T> |
|
ContextAwareGettableComponentSupplier<T> |
Supplier class which is used to get a specific component from AzkarraContext .
|
ContextAwareKafkaStreamsFactorySupplier |
|
ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory |
|
ContextAwareLifecycleInterceptorSupplier |
|
ContextAwareThreadExceptionHandlerSupplier |
|
ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler |
|
ContextAwareTopologySupplier |
|
ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider |
|
Credentials |
Interface to hold a user credentials.
|
Credentials.UnsupportedCredentialException |
|
CustomHealthCheckExample |
Example for registering custom health-check.
|
CustomHealthCheckExample.MyCustomerHealthCheck |
|
DeadLetterTopicExceptionHandler |
A DeserializationExceptionHandler implementation that write rejected records to an dead-letter-topic.
|
DeadLetterTopicExceptionHandlerConfig |
|
DecorateQuery<T extends Query> |
|
DefaultApplicationIdBuilder |
|
DefaultAuthenticationCallbackHandler |
|
DefaultAzkarraContext |
The AzkarraContext.
|
DefaultBannerPrinter |
|
DefaultComponentDescriptorFactory |
|
DefaultComponentFactory |
|
DefaultContainerIdBuilder |
|
DefaultInteractiveQueryService |
A DefaultInteractiveQueryService is used to execute a query request.
|
DefaultStatusAggregator |
|
DefaultStreamThreadExceptionHandlerFactory |
|
DelegateBlockingRecordQueue<K,V> |
|
DelegatingComponentFactory |
|
DelegatingConf |
|
DelegatingExecutionEnvironmentAware<T> |
|
DelegatingUncaughtExceptionHandler |
|
DigestPasswordCredentials |
|
DistributedQueryCall<K,V> |
|
DistributedQueryExecutionDelegatee |
|
Eager |
Annotation that can be used on any class or method directly or indirectly annotated with Component .
|
Either<L,R> |
|
Either.Left<L,R> |
|
Either.LeftProjection<L,R> |
|
Either.Right<L,R> |
|
Either.RightProjection<L,R> |
|
EmbeddedHttpServer |
Default interface to provide an embedded http-server.
|
EmbeddedHttpServerProvider |
|
EmptyConf |
|
EmptyQueryCall<K,V> |
|
EnableAutoConfig |
|
EnableAutoStart |
|
EnableEmbeddedHttpServer |
|
Endpoint |
|
EnvironmentAwareComponentSupplier<T> |
|
EnvironmentConfig |
|
EnvironmentConfig.Reader |
|
EnvironmentRequestBody |
|
EnvironmentsConfigEntryLoader |
|
Error |
|
ErrorMessage |
The error message response object.
|
ErrorResultSet |
|
EventStream<K,V> |
|
EventStream.Builder |
|
EventStreamConnectionCallback |
|
EventStreamPipe<K,V> |
The EventStreamPipe is used to attached or detach an object that will be responsible to consume
records send to an EventStream .
|
EventStreamProvider |
EventStreamsProvider.
|
EventStreamPublisher<K,V> |
The main publisher interface to subscribe to a specific streams of key-value records.
|
EventStreamSupport |
|
ExactlyOnce |
This annotation can be used to automatically set the streams property
processing.guarantee to exactly_once .
|
ExceptionDefaultHandler |
An HttpHandler which used for catching any exception thrown during request execution.
|
ExceptionDefaultResponseListener |
|
ExceptionHeader |
The default record-headers added to record write to the dead-letter-topic.
|
ExchangeHelper |
Simple class to wrap HttpServerExchange instance.
|
Executed |
Executed class is used to describe a Topology instance to be executed.
|
ExecutionException |
|
ExternalComponent |
|
ExternalComponentClassLoader |
|
Factory |
An annotation that can be used by any class having a no-arg constructor
to provide one or many other component implementation.
|
FutureCollectors |
|
GenericQueryParams |
|
GenericRecordSerializer |
|
GetContextResponse |
|
GettableComponent<T> |
Class for getting a configurable component.
|
GlobalConsumerOffsetsRegistry |
|
GlobalResultSet<K,V> |
|
GrantedAuthority |
|
GroupMetricFilter |
|
HasId |
An interface representing a model that has an identifier.
|
HasName |
An interface representing a model that has a name.
|
HeadlessHttpHandler |
|
Health |
The Health wraps information about a service or sub-system.
|
Health.Builder |
Builder for creating new Health instances.
|
HealthAggregator |
|
HealthIndicator |
|
HttpBasicAuth |
|
HttpBearerAuth |
|
HttpClientBuilder |
The HttpClientBuilder can be used for build a new OkHttpClient instance.
|
HttpClientBuilder.AllowAllHostNameVerifier |
|
HttpResource |
|
InMemoryUserIdentityManager |
|
InteractiveQueryService |
A InteractiveQueryService can be used to query a KafkaStreams state store.
|
InteractiveQueryServiceModule |
|
InternalExecuted |
|
InternalStreamsLifeCycleChain |
|
InternalStreamsLifeCycleChain.Callback |
|
InvalidConfException |
|
InvalidHttpQueryParamException |
Exception which is thrown when a param is missing or invalid.
|
InvalidQueryException |
|
InvalidStateStoreQueryException |
Exception which is thrown when an invalid query is received.
|
InvalidStreamsEnvironmentException |
The type Invalid streams environment exception.
|
InvalidStreamsStateException |
|
JAASAuthentication |
|
Json |
Helper class for wrapping ObjectMapper .
|
JSON |
|
JSON.DateTypeAdapter |
Gson TypeAdapter for java.util.Date type
If the dateFormat is null, ISO8601Utils will be used.
|
JSON.OffsetDateTimeTypeAdapter |
Gson TypeAdapter for JSR310 OffsetDateTime type
|
JSON.SqlDateTypeAdapter |
Gson TypeAdapter for java.sql.Date type
If the dateFormat is null, a simple "yyyy-MM-dd" format will be used
(more efficient than SimpleDateFormat).
|
JsonQuerySerde |
Class which is used to serialize / deserialize a JSON query.
|
JvmMeterRegistryBinderFactory |
Factory to register JVM metrics binders.
|
KafkaBrokerReadyInterceptor |
|
KafkaBrokerReadyInterceptorConfig |
|
KafkaMonitoringReporter |
|
KafkaStreamsApplication |
A KafkaStreamsApplication regroups information about KafkaStreams instances that use
the same application.id ,i.e., all instances that belong to the same Kafka Streams application.
|
KafkaStreamsContainer |
A KafkaStreamsContainer is used to encapsulate and to manipulate a KafkaStreams instance
that can be running either locally or remotely.
|
KafkaStreamsContainer.KafkaMetricFilter |
A KafkaMetricFilter can be used to only get specific metrics.
|
KafkaStreamsContainer.StateChangeWatcher |
Watch a KafkaStreams instance for KafkaStreams.State change.
|
KafkaStreamsContainerAware |
Interface to be implemented by any object that wishes to be notified of
the KafkaStreamsContainer that it runs in.
|
KafkaStreamsFactory |
The interface which is used for creating new KafkaStreams instance.
|
KafkaStreamsInstance |
A KafkaStreamsInstance regroups information about a Kafka Streams instance
running either locally or remotely.
|
KafkaStreamsMetadata |
A KafkaStreamsMetadata regroups information about resources assigned to a stream application instance,
i.e., a set of Topic/Partitions and state stores.
|
KafkaStreamsMetadata |
Represents the runtime state of a single KafkaStreams instance.
|
KafkaStreamsMetricsCollector |
Simple Collector implementation for collecting metrics from a KafkaStreams instance.
|
KeyValueCountQuery |
|
KeyValueGetAllQuery<K,V> |
|
KeyValueGetQuery<K,V> |
|
KeyValueGetRangeQuery<K,V> |
|
KeyValueQueryBuilder |
|
KV<K,V> |
Simple key/value pair.
|
LatestVersionQualifier<T> |
|
LimitedQueueCallback |
|
LimitHandler |
The default interface to be used for executing logic when buffer limit is reached.
|
LimitHandler.BlockingQueueLimitReachedException |
|
LimitHandlers |
|
LimitQueueCallback |
|
LocalAzkarraStreamsService |
|
LocalExecutableQuery<K,V> |
Default interface to execute a local state storeName.
|
LocalExecutableQueryWithKey<K1,K2,V> |
|
LocalKafkaStreamsContainer |
|
LocalKafkaStreamsContainerBuilder |
Default builder class for creating and configuring a new wrapped KafkaStreams instance.
|
LocalPreparedQuery<K,V> |
|
LocalPreparedQuery.MissingRequiredKeyError |
|
LocalQueryCall<K,V> |
|
LocalStatePartitionsInfo |
The LocalStatePartitionsInfo describes the state of a state store.
|
LocalStoreAccessor<T> |
Default class to wrap access to local state store.
|
LocalStoreAccessor.StoreSupplier<T> |
|
LocalStoreAccessProvider |
|
LocalStreamsExecution |
|
LocalStreamsExecutionEnvironment |
|
LocalStreamsExecutionEnvironmentFactory |
|
LogAndSkipOnThreadException |
Logs and skips exception when a StreamThread abruptly terminates due to an uncaught exception.
|
LoggingFailureLocalExecutableQuery<K,V> |
|
LoggingStateRestoreListener |
A StateRestoreListener implementation which logs state restoration progress.
|
LogOffsetsFetcher |
|
LongSubscriptionId |
|
MapConf |
A simple Conf implementation which is backed by a HashMap .
|
MeterKafkaStreamsInterceptor |
|
MeterRegistryConfigurer<T extends io.micrometer.core.instrument.MeterRegistry> |
Interface that is used to configure a specific type of MeterRegistry .
|
MeterRegistryFactory |
The default factory to build the primary MeterRegistry .
|
Metric |
|
MetricGroup |
|
MetricNotFoundException |
|
MicrometerMeterRegistryConfigurer |
The default MeterRegistryConfigurer implementation to register a collection of
MeterBinder and MeterFilter on any MeterRegistry .
|
MissingConfException |
|
MonitoringReporter |
A MonitoringStreamsReporter can be used to periodically report the state of
a local KafkaStreams instance.
|
MonitoringStreamsInterceptor |
Interceptor to monitor KafkaStreams instance.
|
MonitoringStreamsInterceptorConfig |
|
MonitoringStreamsTask |
Task for reporting KafkaStreams state changes.
|
MonitoringStreamsTask.Reportable<T> |
|
MonitorOffsetsConsumerInterceptor<K,V> |
Default ConsumerInterceptor that is used to track consumption progress.
|
NamedQualifier<T> |
|
NameMetricFilter |
|
Network |
|
NonNullMetricFilter |
|
NoopConfigEntryLoader |
|
NoSuchComponentException |
|
NoSuchComponentException |
|
NotFoundException |
|
NoUniqueComponentException |
|
OffsetAndTimestamp |
|
OffsetAndTimestampSerializer |
|
OnComponentCondition |
|
OnPropertyCondition<T> |
Condition to express a requirement for a given property.
|
OpaqueMemoryResource<T> |
An OpaqueMemoryResource represents a shared memory resource.
|
OptimizedTopologyProvider |
|
Order |
|
Ordered |
|
Pair |
|
ParsingConfException |
|
PasswordCredentials |
|
PasswordCredentials.Type |
|
PlainPasswordCredentials |
Representation of a plain text user password.
|
Primary |
Marker interface to indicate that a component must be selected
in the case of multiple possible implementations.
|
PrimaryQualifier<T> |
|
ProgressRequestBody |
|
ProgressResponseBody |
|
PrometheusEndpoint |
Endpoint to scrap metrics in prometheus format.
|
PrometheusEndpoint.PrometheusEndpointExtension |
|
PropertiesFileLoginModule |
This LoginModule imports a user's Principal and credentials information (BasicUserPrincipal,
BasicRolePrincipal, UserPasswordCredentials) and associates them with the current Subject.
|
PropertiesFileUsersIdentityManager |
|
Property |
A single key-value with configuration.
|
Provider<T> |
Interface to provide versioned components.
|
Qualifier<T> |
|
Qualifiers |
|
Query |
|
QueryableKafkaStreams |
|
QueryBuilder |
|
QueryCall<K,V> |
A QueryCall is a query that has been prepared for execution.
|
QueryCall.QueryCallFactory |
A QueryCallFactory is used to create new QueryCall .
|
QueryConstants |
|
QueryError |
A serializable error.
|
QueryExecutionDelegatee |
A QueryExecutionDelegatee is used to plug a specific strategy to execute a state store query.
|
QueryOperationBuilder |
|
QueryOptions |
The QueryOptions cane be used to set the options to be used
for querying a state store.
|
QueryOptionsRequest |
Class which is used for serializing and de-serializing state store query options.
|
QueryParams |
|
QueryRequest |
Class which is use to wrap information about the store to be query.
|
QueryResult<K,V> |
|
QueryResultBuilder<K,V> |
|
QueryResultUtils |
|
QueryStatus |
|
QueueCallback |
|
Reader<A,B> |
|
ReflectiveComponentScanner |
|
ReflectMethodComponentSupplier |
|
RemoteQueryCallFactory |
|
ResourceDisposer<E extends Throwable> |
A MemoryResourceDisposer can be used to dispose a shared
resource after it is not used any more.
|
ResourceInitializer<T> |
A ResourceInitializer is used to initialize a new resource.
|
RestApiQueryCall<K,V> |
A RestApiQueryCall can be used to execute an interactive query on a remote instance.
|
RestApiQueryCallFactory |
|
RestartKafkaStreamsOnThreadException |
Restarts the KafkaStreams instance when a StreamThread
abruptly terminates due to an uncaught exception.
|
Restricted |
Marker interface that a class annotated with Component can used for describing its scope.
|
RestrictedComponentFactory |
|
Restriction |
|
RestrictionQualifier<T> |
|
Retry |
|
RocksDBConfig |
The RocksDBConfig can be used to easily build a Conf for RocksDB.
|
RoleGrantedAuthority |
|
RoutingHandlerProvider |
|
SafeDeserializer<T> |
|
SafeDeserializerConfig |
|
SafeSerdes |
Factory for creating serializers / safe-deserializers.
|
Secondary |
Marker interface to indicate that a component must be de-prioritize
in the case of multiple possible implementations.
|
SecondaryQualifier<T> |
|
SecurityConfException |
|
SecurityConfig |
The server security confiugration.
|
SecurityHandler |
SecurityHandler.
|
SecurityHandlerFactory |
|
SecurityMechanism |
List of security mechanism currently supported for authenticating users.
|
SequentialSubscriptionIdGenerator |
|
Serdes<T> |
Interface for serializing and de-serializing object.
|
SerializationException |
|
ServerConfig |
The server configuration.
|
ServerConfigBuilder |
An helper class for build a Conf used for configuring embedded http-server.
|
ServerConfigEntryLoader |
|
ServerConfiguration |
Representing a Server configuration.
|
ServerInfo |
|
ServerSentEventExample |
|
ServerSentEventExample.WordCountPublisherTopology |
|
ServerSentEventSubscriber<K,V> |
A subscriber that sent published KV records over HTTP using a Server-Sent Event (SSE) connection.
|
ServerSentEventSubscriber.StreamedEvent |
|
ServerVariable |
Representing a Server Variable for server URL template substitution.
|
SessionFetchKeyRangeQuery<K,V> |
|
SessionFetchQuery<K,V> |
|
SessionQueryBuilder |
|
ShutdownHook |
Utility class for registering shutdown hooks.
|
ShutdownHook.Hook |
|
SimpleAuthorizationManager |
SimpleAuthorizationManager.
|
SimpleComponentDescriptor<T> |
|
SL4JLoggerPrintStream |
|
SpecificJsonSerdes<T> |
|
SSLAuthenticationContext |
SSLSecurityContext.
|
SSLAuthenticationExample |
Example to configure an azkarra application with SSL-Two-Way authentication.
|
SSLClientAuthentication |
|
SSLContextFactory |
Default class for retrieving a new SSLContext instance.
|
SSLUtils |
Utility class for SSL.
|
State |
The states.
|
State |
|
State.Standards |
The standard State for a KafkaStreams instance.
|
StateChangeEvent |
|
StatePartitionLagInfo |
|
StatePartitionRestoreInfo |
Describes the state of a restoration process for TopicPartition .
|
StateRestoreInfo |
Describes the state of a restoration process for state store.
|
StateRestoreService |
The StateRestoreService is used to get information about the
states of the restoration process of a StateStore.
|
Status |
|
StatusAggregator |
|
StopWordsService |
|
StoreOperation |
|
StoreType |
The store types supported by KafkaStreams .
|
StreamsApplication |
|
StreamsApplication |
Example to manually register a topology.
|
StreamsApplicationResponse |
|
StreamsConfigEntryLoader |
|
StreamsExecutionEnvironment<T extends StreamsExecutionEnvironment<T>> |
A StreamsExecutionEnvironment manages the execution and the lifecycle of one or many KafkaStreams
instances that run either locally or remotely.
|
StreamsExecutionEnvironment.View |
|
StreamsExecutionEnvironmentAbstractFactory |
|
StreamsExecutionEnvironmentAware |
|
StreamsExecutionEnvironmentFactory<T extends StreamsExecutionEnvironment<T>> |
|
StreamsExtensionBuilder |
|
StreamsGetMetricsHandler |
|
StreamsHealthIndicator |
|
StreamsInstanceInfo |
|
StreamsInstanceInfo.Builder |
|
StreamsInstanceInfo.State |
|
StreamsInstanceStatus |
|
StreamsLifecycleChain |
|
StreamsLifecycleContext |
Context about the current KafkaStreams instance.
|
StreamsLifecycleInterceptor |
An interface that allows to intercept a KafkaStreams instance before being
started or stopped.
|
StreamsName |
Marker interface that a TopologyProvider can used to set the default
name attached to the streams instance.
|
StreamsPostHandler |
|
StreamsStopHandler |
|
StreamsTopologyExecution |
TopologyExecution provide a way for topology to be executed in an specific environment.
|
StreamsTopologyGraph |
A Serializable streams topology graph.
|
StreamsTopologyGraph.AbstractNode |
An abstract topology node.
|
StreamsTopologyGraph.GlobalStore |
|
StreamsTopologyGraph.Node |
|
StreamsTopologyGraph.Node.Type |
|
StreamsTopologyGraph.ProcessorNode |
A topology processor-node.
|
StreamsTopologyGraph.ProcessorNodeBuilder |
|
StreamsTopologyGraph.SinkNode |
A topology sink-node.
|
StreamsTopologyGraph.SinkNodeBuilder |
|
StreamsTopologyGraph.SourceNode |
A topology source-node.
|
StreamsTopologyGraph.SourceNodeBuilder |
|
StreamsTopologyGraph.SubTopologyGraph |
|
StreamsTopologyMeta |
|
StreamsTopologyMeta.Builder |
|
StreamsTopologyRequest |
|
StreamThreadExceptionHandler |
Interface that specifies how to handle an uncaught exception from a
StreamThread .
|
StringUtil |
|
SubscriptionId |
Default interface that is used to wrap a subscription identifier.
|
SubscriptionIdGenerator |
|
SuccessResultSet<K,V> |
|
SystemTime |
|
TaskMetadataSerializer |
|
ThreadMetadataSerializer |
|
Time |
|
TimestampedKeyValueGetAllQuery<K,V> |
|
TimestampedKeyValueGetQuery<K,V> |
|
TimestampedKeyValueGetRangeQuery<K,V> |
|
TimestampedKeyValueQueryBuilder |
|
TimestampedValue<V> |
|
TimestampedWindowFetchAllQuery<K,V> |
|
TimestampedWindowFetchKeyRangeQuery<K,V> |
|
TimestampedWindowFetchQuery<K,V> |
|
TimestampedWindowFetchTimeRangeQuery<K,V> |
|
TimestampedWindowGetAllQuery<K,V> |
|
TimestampedWindowQueryBuilder |
|
TimestampSerializer |
|
TopicPartitions |
This class represents topic-partitions assignment for a streams application.
|
TopicPartitionSerializer |
The JsonSerializer to serialize TopicPartition instance.
|
TopologyAndAliases |
|
TopologyConfig |
|
TopologyConfig.Reader |
|
TopologyDefinition |
|
TopologyDescriptor<T extends TopologyProvider> |
|
TopologyDescriptorSerializer |
|
TopologyInfo |
Marker interface that a TopologyProvider can used to describe
the behavior of the provided Topology .
|
TopologyMetadata |
|
TopologyProvider |
The default interface to supply a Kafka Streams Topology instance.
|
TopologyUtils |
|
TrueCondition |
Returns true .
|
Try<V> |
|
Try.Failure<V> |
|
Try.Retriable<V> |
|
Try.Success<V> |
|
Tuple<L,R> |
|
TypeConverter |
Class which can be used to convert an object to a specific type.
|
UnauthorizedAccessException |
|
UndertowAuthenticationContext |
|
UndertowEmbeddedServer |
|
UndertowEmbeddedServer.InternalRestExtensionContext |
|
UndertowEmbeddedServerProvider |
|
UserDetails |
|
UsernamePasswordAuthentication |
|
UsersIdentityManager |
|
Utils |
|
V1Error |
V1Error
|
V1LocalStatePartitionsInfo |
V1LocalStatePartitionsInfo
|
V1Metric |
V1Metric
|
V1MetricGroup |
V1MetricGroup
|
V1Options |
V1Options
|
V1Query |
V1Query
|
V1Query.TypeEnum |
Gets or Sets type
|
V1Query.TypeEnum.Adapter |
|
V1QueryAll |
V1QueryAll
|
V1QueryBuilder |
|
V1QueryCount |
V1QueryCount
|
V1QueryErrorResultSet |
V1QueryErrorResultSet
|
V1QueryFetch |
V1QueryFetch
|
V1QueryFetchAll |
V1QueryFetchAll
|
V1QueryFetchAllParams |
V1QueryFetchAllParams
|
V1QueryFetchKeyRange |
V1QueryFetchKeyRange
|
V1QueryFetchKeyRangeParams |
V1QueryFetchKeyRangeParams
|
V1QueryFetchParams |
V1QueryFetchParams
|
V1QueryFetchTimeRange |
V1QueryFetchTimeRange
|
V1QueryFetchTimeRangeParams |
V1QueryFetchTimeRangeParams
|
V1QueryGet |
V1QueryGet
|
V1QueryGetParams |
V1QueryGetParams
|
V1QueryGlobalResultSet |
V1QueryGlobalResultSet
|
V1QueryOperation |
V1QueryOperation
|
V1QueryOptions |
V1QueryOptions
|
V1QueryRange |
V1QueryRange
|
V1QueryRangeParams |
V1QueryRangeParams
|
V1QueryResult |
V1QueryResult
|
V1QueryResult.StatusEnum |
Gets or Sets status
|
V1QueryResult.StatusEnum.Adapter |
|
V1QuerySuccessResultSet |
V1QuerySuccessResultSet
|
V1Record |
V1Record
|
V1StatePartitionLagInfo |
V1StatePartitionLagInfo
|
V1StatePartitionRestoreInfo |
V1StatePartitionRestoreInfo
|
V1StreamsConsumerClientOffsets |
V1StreamsConsumerClientOffsets
|
V1StreamsConsumerGroupOffsets |
V1StreamsConsumerGroupOffsets
|
V1StreamsConsumerLogOffsets |
V1StreamsConsumerLogOffsets
|
V1StreamsDetails |
V1StreamsDetails
|
V1StreamsGlobalStore |
V1StreamsGlobalStore
|
V1StreamsMetadata |
V1StreamsMetadata
|
V1StreamsState |
V1StreamsState
|
V1StreamsStatus |
V1StreamsStatus
|
V1StreamsSubTopology |
V1StreamsSubTopology
|
V1StreamsTopology |
V1StreamsTopology
|
V1StreamsTopologyNode |
V1StreamsTopologyNode
|
V1StreamsTopologyProcessorNode |
V1StreamsTopologyProcessorNode
|
V1StreamsTopologyProcessorNodeAllOf |
V1StreamsTopologyProcessorNodeAllOf
|
V1StreamsTopologySinkNode |
V1StreamsTopologySinkNode
|
V1StreamsTopologySinkNodeAllOf |
V1StreamsTopologySinkNodeAllOf
|
V1StreamsTopologySourceNode |
V1StreamsTopologySourceNode
|
V1StreamsTopologySourceNodeAllOf |
V1StreamsTopologySourceNodeAllOf
|
V1TaskMetadata |
V1TaskMetadata
|
V1ThreadMetadata |
V1ThreadMetadata
|
V1TopicPartition |
V1TopicPartition
|
Validator<T> |
|
Version |
A version class which supports the following pattern :
..-
Supported qualifier are : alpha, beta, snapshot, rc, release.
|
Version |
Version
|
Version |
|
Versioned |
|
VersionQualifier<T> |
|
VisibleForTesting |
|
WaitForSourceTopicsInterceptor |
|
WaitForSourceTopicsInterceptorConfig |
|
WebUIHttpRoutes |
|
WindowedSerializer |
The JsonSerializer to serialize Windowed instance.
|
WindowFetchAllQuery<K,V> |
|
WindowFetchKeyRangeQuery<K,V> |
|
WindowFetchQuery<K,V> |
|
WindowFetchTimeRangeQuery<K,V> |
|
WindowGetAllQuery<K,V> |
|
WindowQueryBuilder |
|
X509CertificateCredentials |
X509CertificateCredentials.
|
XMLHttpRequestAwareAuthCallHandler |
This is the final HttpHandler in the security chain, it's purpose is to act as a
barrier at the end of the chain to ensure authenticate is called after the mechanisms have been associated
with the context and the constraint checked.
|