All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
Class |
Description |
AbstractConfig |
A convenient base class for configurations to extend.
|
AbstractOptions<T extends AbstractOptions> |
|
AbstractProcessor<K,V> |
|
AbstractProcessorContext |
|
AbstractRocksDBSegmentedBytesStore<S extends Segment> |
|
AbstractState |
Provides the current status along with identifier for Connect worker and tasks.
|
AbstractStoreBuilder<K,V,T extends StateStore> |
|
AbstractStream<K,V> |
|
AbstractTask |
|
AccessControlEntry |
Represents an access control entry.
|
AccessControlEntryFilter |
Represents a filter which matches access control entries.
|
AclBinding |
Represents a binding between a resource pattern and an access control entry.
|
AclBindingFilter |
A filter which can match AclBinding objects.
|
AclCreateResult |
|
AclDeleteResult |
|
AclDeleteResult.AclBindingDeleteResult |
Delete result for each ACL binding that matched a delete filter.
|
AclOperation |
Represents an operation which an ACL grants or denies permission to perform.
|
AclPermissionType |
Represents whether an ACL grants or denies permissions.
|
Action |
|
Admin |
The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs.
|
AdminClient |
The base class for in-built admin clients.
|
AdminClientConfig |
The AdminClient configuration class, which also contains constants for configuration entry names.
|
Aggregator<K,V,VA> |
The Aggregator interface for aggregating values of the given key.
|
AlreadyExistsException |
Indicates the operation tried to create an entity that already exists.
|
AlterClientQuotasOptions |
|
AlterClientQuotasResult |
|
AlterConfigOp |
A class representing a alter configuration entry containing name, value and operation type.
|
AlterConfigOp.OpType |
|
AlterConfigPolicy |
An interface for enforcing a policy on alter configs requests.
|
AlterConfigPolicy.RequestMetadata |
Class containing the create request parameters.
|
AlterConfigsOptions |
|
AlterConfigsResult |
|
AlterConsumerGroupOffsetsOptions |
|
AlterConsumerGroupOffsetsResult |
|
AlterPartitionReassignmentsOptions |
|
AlterPartitionReassignmentsResult |
|
AlterReplicaLogDirsOptions |
|
AlterReplicaLogDirsResult |
|
ApiException |
Any API exception that is part of the public protocol and should be a subclass of this class and be part of this
package.
|
ApiUtils |
|
AssignmentInfo |
|
AssignorConfiguration |
|
AssignorConfiguration.AssignmentConfigs |
|
AssignorConfiguration.AssignmentListener |
|
AssignorError |
|
AuthenticateCallbackHandler |
|
AuthenticationContext |
An object representing contextual information from the authentication session.
|
AuthenticationException |
This exception indicates that SASL authentication has failed.
|
AuthorizableRequestContext |
Request context interface that provides data from request header as well as connection
and authentication information to plugins.
|
AuthorizationException |
|
AuthorizationResult |
|
Authorizer |
Pluggable authorizer interface for Kafka brokers.
|
AuthorizerServerInfo |
Runtime broker configuration metadata provided to authorizers during start up.
|
BaseRepartitionNode<K,V> |
|
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T extends BaseRepartitionNode<K,V>> |
|
BatchingStateRestoreCallback |
|
BatchWritingStore |
|
BrokerNotAvailableException |
|
BrokerNotFoundException |
Indicates that none of the specified brokers
could be found.
|
BufferConfigInternal<BC extends Suppressed.BufferConfig<BC>> |
|
BufferExhaustedException |
This exception is thrown if the producer cannot allocate memory for a record within max.block.ms due to the buffer
being too full.
|
BufferFullStrategy |
|
BufferKey |
|
BufferValue |
|
ByteArrayDeserializer |
|
ByteArraySerializer |
|
ByteBufferDeserializer |
|
ByteBufferSerializer |
|
BytesDeserializer |
|
BytesSerializer |
|
CachedStateStore<K,V> |
|
CacheFlushListener<K,V> |
Listen to cache flush events
|
CachingKeyValueStore |
|
Callback |
A callback interface that the user can implement to allow code to execute when the request is complete.
|
Cancellable |
|
Change<T> |
|
ChangedDeserializer<T> |
|
ChangedSerializer<T> |
|
ChangeLoggingKeyValueBytesStore |
|
ChangeLoggingTimestampedKeyValueBytesStore |
|
ChangelogReader |
|
ChangelogRegister |
|
Checkpoint |
Checkpoint records emitted from MirrorCheckpointConnector.
|
ClientMetrics |
|
ClientQuotaCallback |
Quota callback interface for brokers that enables customization of client quota computation.
|
ClientQuotaEntity |
The metadata for an entity for which quota is configured.
|
ClientQuotaEntity.ConfigEntity |
Interface representing a quota configuration entity.
|
ClientQuotaEntity.ConfigEntityType |
|
ClientQuotaType |
Types of quotas that may be configured on brokers for client requests.
|
ClientState |
|
ClientUtils |
|
ClientUtils.QuietAdminClientConfig |
|
Cluster |
An immutable representation of a subset of the nodes, topics, and partitions in the Kafka cluster.
|
ClusterAuthorizationException |
|
ClusterResource |
The ClusterResource class encapsulates metadata for a Kafka cluster.
|
ClusterResourceListener |
A callback interface that users can implement when they wish to get notified about changes in the Cluster metadata.
|
CogroupedKStream<K,VOut> |
CogroupedKStream is an abstraction of multiple grouped record streams of KeyValue pairs.
|
CogroupedKStreamImpl<K,VOut> |
|
CombinedKey<KF,KP> |
|
CombinedKeySchema<KO,K> |
Factory for creating CombinedKey serializers / deserializers.
|
CommitFailedException |
|
CompositeReadOnlyKeyValueStore<K,V> |
|
CompositeReadOnlySessionStore<K,V> |
|
CompositeReadOnlyWindowStore<K,V> |
|
ConcurrentTransactionsException |
|
Config |
A configuration object containing the configuration entries for a resource.
|
Config |
|
ConfigChangeCallback |
|
ConfigData |
|
ConfigDef |
This class is used for specifying the set of expected configurations.
|
ConfigDef.CaseInsensitiveValidString |
|
ConfigDef.CompositeValidator |
|
ConfigDef.ConfigKey |
|
ConfigDef.Importance |
The importance level for a configuration
|
ConfigDef.LambdaValidator |
|
ConfigDef.NonEmptyString |
|
ConfigDef.NonEmptyStringWithoutControlChars |
|
ConfigDef.NonNullValidator |
|
ConfigDef.Range |
Validation logic for numeric ranges
|
ConfigDef.Recommender |
This is used by the ConfigDef.validate(Map) to get valid values for a configuration given the current
configuration values in order to perform full configuration validation and visibility modification.
|
ConfigDef.Type |
The config types
|
ConfigDef.Validator |
Validation logic the user may provide to perform single configuration validation.
|
ConfigDef.ValidList |
|
ConfigDef.ValidString |
|
ConfigDef.Width |
The width of a configuration value
|
ConfigEntry |
A class representing a configuration entry containing name, value and additional metadata.
|
ConfigEntry.ConfigSource |
Source of configuration entries.
|
ConfigEntry.ConfigSynonym |
Class representing a configuration synonym of a ConfigEntry .
|
ConfigEntry.ConfigType |
Data type of configuration entry.
|
ConfigException |
Thrown if the user supplies an invalid configuration
|
ConfigProvider |
A provider of configuration data, which may optionally support subscriptions to configuration changes.
|
ConfigResource |
A class representing resources that have configs.
|
ConfigResource.Type |
Type of resource.
|
ConfigTransformer |
This class wraps a set of ConfigProvider instances and uses them to perform
transformations.
|
ConfigTransformerResult |
|
Configurable |
A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters
|
ConfigValue |
|
ConnectClusterDetails |
Provides immutable Connect cluster information, such as the ID of the backing Kafka cluster.
|
ConnectClusterState |
Provides the ability to lookup connector metadata, including status and configurations, as well
as immutable cluster information such as Kafka cluster ID.
|
ConnectedStoreProvider |
Provides a set of StoreBuilder s that will be automatically added to the topology and connected to the
associated processor.
|
ConnectException |
ConnectException is the top-level exception type generated by Kafka Connect and connector implementations.
|
ConnectHeaders |
|
Connector |
Connectors manage integration of Kafka Connect with another system, either as an input that ingests
data into Kafka or an output that passes data to an external system.
|
ConnectorClientConfigOverridePolicy |
An interface for enforcing a policy on overriding of client configs via the connector configs.
|
ConnectorClientConfigRequest |
|
ConnectorClientConfigRequest.ClientType |
|
ConnectorContext |
ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.
|
ConnectorHealth |
Provides basic health information about the connector and its tasks.
|
ConnectorState |
Describes the status, worker ID, and any errors associated with a connector.
|
ConnectorType |
Enum definition that identifies the type of the connector.
|
ConnectorUtils |
Utilities that connector implementations might find useful.
|
ConnectRecord<R extends ConnectRecord<R>> |
Base class for records containing data to be copied to/from Kafka.
|
ConnectRestExtension |
A plugin interface to allow registration of new JAX-RS resources like Filters, REST endpoints, providers, etc.
|
ConnectRestExtensionContext |
|
ConnectSchema |
|
Consumed<K,V> |
|
ConsumedInternal<K,V> |
|
Consumer<K,V> |
|
ConsumerConfig |
The consumer configuration keys
|
ConsumerGroupDescription |
A detailed description of a single consumer group in the cluster.
|
ConsumerGroupListing |
A listing of a consumer group in the cluster.
|
ConsumerGroupMetadata |
A metadata struct containing the consumer group information.
|
ConsumerGroupState |
The consumer group state.
|
ConsumerInterceptor<K,V> |
A plugin interface that allows you to intercept (and possibly mutate) records received by the consumer.
|
ConsumerPartitionAssignor |
This interface is used to define custom partition assignment for use in
KafkaConsumer .
|
ConsumerPartitionAssignor.Assignment |
|
ConsumerPartitionAssignor.GroupAssignment |
|
ConsumerPartitionAssignor.GroupSubscription |
|
ConsumerPartitionAssignor.RebalanceProtocol |
The rebalance protocol defines partition assignment and revocation semantics.
|
ConsumerPartitionAssignor.Subscription |
|
ConsumerRebalanceListener |
A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the
consumer changes.
|
ConsumerRecord<K,V> |
A key/value pair to be received from Kafka.
|
ConsumerRecordFactory<K,V> |
Deprecated.
|
ConsumerRecords<K,V> |
A container that holds the list ConsumerRecord per partition for a
particular topic.
|
ContextualRecord |
|
ControllerMovedException |
|
Converter |
The Converter interface provides support for translating between Kafka Connect's runtime data format
and byte[].
|
ConverterConfig |
|
ConverterType |
|
CooperativeStickyAssignor |
A cooperative version of the AbstractStickyAssignor .
|
CoordinatorLoadInProgressException |
In the context of the group coordinator, the broker returns this error code for any coordinator request if
it is still loading the group metadata (e.g.
|
CoordinatorNotAvailableException |
In the context of the group coordinator, the broker returns this error code for metadata or offset commit
requests if the group metadata topic has not been created yet.
|
CopartitionedTopicsEnforcer |
|
CorruptRecordException |
This exception indicates a record has failed its internal CRC check, this generally indicates network or disk
corruption.
|
CreateAclsOptions |
|
CreateAclsResult |
|
CreateDelegationTokenOptions |
|
CreateDelegationTokenResult |
|
CreatePartitionsOptions |
|
CreatePartitionsResult |
|
CreateTopicPolicy |
An interface for enforcing a policy on create topics requests.
|
CreateTopicPolicy.RequestMetadata |
Class containing the create request parameters.
|
CreateTopicsOptions |
|
CreateTopicsResult |
|
CreateTopicsResult.TopicMetadataAndConfig |
|
DataException |
Base class for all Kafka Connect data API exceptions.
|
Date |
A date representing a calendar day with no time of day or timezone.
|
Decimal |
An arbitrary-precision signed decimal number.
|
DefaultKafkaClientSupplier |
|
DefaultPartitionGrouper |
Deprecated.
|
DefaultPrincipalBuilder |
Deprecated.
|
DefaultProductionExceptionHandler |
ProductionExceptionHandler that always instructs streams to fail when an exception
happens while attempting to produce result records.
|
DefaultReplicationPolicy |
Defines remote topics like "us-west.topic1".
|
DefaultStreamPartitioner<K,V> |
|
DefaultStreamsPartitioner |
|
DelegatingPeekingKeyValueIterator<K,V> |
Optimized KeyValueIterator used when the same element could be peeked multiple times.
|
DelegationToken |
A class representing a delegation token.
|
DelegationTokenAuthorizationException |
|
DelegationTokenDisabledException |
|
DelegationTokenExpiredException |
|
DelegationTokenNotFoundException |
|
DelegationTokenOwnerMismatchException |
|
DeleteAclsOptions |
|
DeleteAclsResult |
|
DeleteAclsResult.FilterResult |
A class containing either the deleted ACL binding or an exception if the delete failed.
|
DeleteAclsResult.FilterResults |
A class containing the results of the delete ACLs operation.
|
DeleteConsumerGroupOffsetsOptions |
|
DeleteConsumerGroupOffsetsResult |
|
DeleteConsumerGroupsOptions |
|
DeleteConsumerGroupsResult |
|
DeletedRecords |
Represents information about deleted records
The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
|
DeleteRecordsOptions |
|
DeleteRecordsResult |
|
DeleteTopicsOptions |
|
DeleteTopicsResult |
|
DescribeAclsOptions |
|
DescribeAclsResult |
|
DescribeClientQuotasOptions |
|
DescribeClientQuotasResult |
|
DescribeClusterOptions |
|
DescribeClusterResult |
|
DescribeConfigsOptions |
|
DescribeConfigsResult |
|
DescribeConsumerGroupsOptions |
|
DescribeConsumerGroupsResult |
|
DescribeDelegationTokenOptions |
|
DescribeDelegationTokenResult |
|
DescribeLogDirsOptions |
|
DescribeLogDirsResult |
|
DescribeReplicaLogDirsOptions |
|
DescribeReplicaLogDirsResult |
|
DescribeReplicaLogDirsResult.ReplicaLogDirInfo |
|
DescribeTopicsOptions |
|
DescribeTopicsResult |
|
DeserializationExceptionHandler |
Interface that specifies how an exception from source node deserialization
(e.g., reading from Kafka) should be handled.
|
DeserializationExceptionHandler.DeserializationHandlerResponse |
Enumeration that describes the response from the exception handler.
|
Deserializer<T> |
An interface for converting bytes to objects.
|
DisconnectException |
Server disconnected before a request could be completed.
|
DoubleDeserializer |
|
DoubleSerializer |
|
DuplicateSequenceException |
|
EagerBufferConfigImpl |
|
ElectionNotNeededException |
|
ElectionType |
|
ElectLeadersOptions |
|
ElectLeadersResult |
|
ElectPreferredLeadersOptions |
Deprecated.
|
ElectPreferredLeadersResult |
Deprecated.
|
EligibleLeadersNotAvailableException |
|
Endpoint |
Represents a broker endpoint.
|
ErrantRecordReporter |
|
ExpireDelegationTokenOptions |
|
ExpireDelegationTokenResult |
|
ExtendedDeserializer<T> |
Deprecated.
|
ExtendedDeserializer.Wrapper<T> |
|
ExtendedSerializer<T> |
Deprecated.
|
ExtendedSerializer.Wrapper<T> |
|
FailOnInvalidTimestamp |
Retrieves embedded metadata timestamps from Kafka messages.
|
FallbackPriorTaskAssignor |
A special task assignor implementation to be used as a fallback in case the
configured assignor couldn't be invoked.
|
FencedInstanceIdException |
|
FencedLeaderEpochException |
The request contained a leader epoch which is smaller than that on the broker that received the
request.
|
FetchSessionIdNotFoundException |
|
Field |
A field in a Struct , consisting of a field name, index, and Schema for the field value.
|
FileConfigProvider |
An implementation of ConfigProvider that represents a Properties file.
|
FinalResultsSuppressionBuilder<K extends Windowed> |
|
FloatDeserializer |
|
FloatSerializer |
|
ForeachAction<K,V> |
The ForeachAction interface for performing an action on a key-value
pair .
|
ForeignJoinSubscriptionProcessorSupplier<K,KO,VO> |
|
ForeignJoinSubscriptionSendProcessorSupplier<K,KO,V> |
|
ForwardingDisabledProcessorContext |
ProcessorContext implementation that will throw on any forward call.
|
FullChangeSerde<T> |
|
GenericCoordinator |
|
GlobalKTable<K,V> |
GlobalKTable is an abstraction of a changelog stream from a primary-keyed table.
|
GlobalKTableImpl<K,V> |
|
GlobalProcessorContextImpl |
|
GlobalStateManager |
|
GlobalStateManagerImpl |
This class is responsible for the initialization, restoration, closing, flushing etc
of Global State Stores.
|
GlobalStateStoreProvider |
|
GlobalStateUpdateTask |
Updates the state for all Global State Stores.
|
GlobalStoreNode<K,V,S extends StateStore> |
|
GlobalStreamThread |
This is the thread responsible for keeping all Global State Stores updated.
|
GlobalStreamThread.State |
The states that the global stream thread can be in
|
GraphGraceSearchUtil |
|
GroupAuthorizationException |
|
Grouped<K,V> |
|
GroupedInternal<K,V> |
|
GroupedTableOperationRepartitionNode<K,V> |
|
GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> |
|
GroupIdNotFoundException |
|
GroupMaxSizeReachedException |
Indicates that a consumer group is already at its configured maximum capacity and cannot accommodate more members
|
GroupNotEmptyException |
|
GroupSubscribedToTopicException |
|
Header |
|
Header |
A Header is a key-value pair, and multiple headers can be included with the key, value, and timestamp in each Kafka message.
|
HeaderConverter |
|
Headers |
|
Headers |
A mutable ordered collection of Header objects.
|
Headers.HeaderTransform |
A function to transform the supplied Header .
|
Heartbeat |
Heartbeat message sent from MirrorHeartbeatTask to target cluster.
|
HighAvailabilityTaskAssignor |
|
HostInfo |
Represents a user defined endpoint in a KafkaStreams application.
|
IllegalGenerationException |
|
IllegalSaslStateException |
This exception indicates unexpected requests prior to SASL authentication.
|
IllegalWorkerStateException |
Indicates that a method has been invoked illegally or at an invalid time by a connector or task.
|
InconsistentGroupProtocolException |
|
Initializer<VA> |
The Initializer interface for creating an initial value in aggregations.
|
InMemoryKeyValueStore |
|
InMemorySessionBytesStoreSupplier |
|
InMemorySessionStore |
|
InMemoryTimeOrderedKeyValueBuffer<K,V> |
|
InMemoryTimeOrderedKeyValueBuffer.Builder<K,V> |
|
InMemoryWindowBytesStoreSupplier |
|
InMemoryWindowStore |
|
IntegerDeserializer |
|
IntegerSerializer |
|
InterfaceStability |
Annotation to inform users of how much to rely on a particular package, class or method not changing over time.
|
InterfaceStability.Evolving |
Compatibility may be broken at minor release (i.e.
|
InterfaceStability.Stable |
Compatibility is maintained in major, minor and patch releases with one exception: compatibility may be broken
in a major release (i.e.
|
InterfaceStability.Unstable |
No guarantee is provided as to reliability or stability across any level of release granularity.
|
InternalNameProvider |
|
InternalProcessorContext |
|
InternalStreamNotExistException |
|
InternalStreamsBuilder |
|
InternalTopicConfig |
InternalTopicConfig captures the properties required for configuring
the internal topics we create for change-logs and repartitioning etc.
|
InternalTopicManager |
|
InternalTopicProperties |
|
InternalTopologyBuilder |
|
InternalTopologyBuilder.AbstractNode |
|
InternalTopologyBuilder.GlobalStore |
|
InternalTopologyBuilder.Processor |
|
InternalTopologyBuilder.Sink<K,V> |
|
InternalTopologyBuilder.Source |
|
InternalTopologyBuilder.StateStoreFactory<S extends StateStore> |
|
InternalTopologyBuilder.Subtopology |
|
InternalTopologyBuilder.TopicsInfo |
|
InternalTopologyBuilder.TopologyDescription |
|
InterruptException |
An unchecked wrapper for InterruptedException
|
InvalidCommitOffsetSizeException |
|
InvalidConfigurationException |
|
InvalidFetchSessionEpochException |
|
InvalidFetchSizeException |
|
InvalidGroupIdException |
|
InvalidMetadataException |
An exception that may indicate the client's metadata is out of date
|
InvalidOffsetException |
Thrown when the offset for a set of partitions is invalid (either undefined or out of range),
and no reset policy has been configured.
|
InvalidOffsetException |
Thrown when the offset for a set of partitions is invalid (either undefined or out of range),
and no reset policy has been configured.
|
InvalidPartitionsException |
|
InvalidPidMappingException |
|
InvalidPrincipalTypeException |
|
InvalidRecordException |
|
InvalidReplicaAssignmentException |
|
InvalidReplicationFactorException |
|
InvalidRequestException |
Thrown when a request breaks basic wire protocol rules.
|
InvalidRequiredAcksException |
|
InvalidSessionTimeoutException |
|
InvalidStateStoreException |
Indicates that there was a problem when trying to access a
StateStore , i.e, the Store is no longer valid because it is
closed or doesn't exist any more due to a rebalance.
|
InvalidTimestampException |
Indicate the timestamp of a record is invalid.
|
InvalidTopicException |
The client has attempted to perform an operation on an invalid topic.
|
InvalidTxnStateException |
|
InvalidTxnTimeoutException |
The transaction coordinator returns this error code if the timeout received via the InitProducerIdRequest is larger than
the `transaction.max.timeout.ms` config value.
|
IsolationLevel |
|
Joined<K,V,VO> |
|
JoinedInternal<K,V,VO> |
|
JoinWindows |
The window specifications used for joins.
|
KafkaAdminClient |
The default implementation of Admin .
|
KafkaClientSupplier |
KafkaClientSupplier can be used to provide custom Kafka clients to a KafkaStreams instance.
|
KafkaConsumer<K,V> |
A client that consumes records from a Kafka cluster.
|
KafkaException |
The base class of all other Kafka exceptions
|
KafkaFuture<T> |
A flexible future which supports call chaining and other asynchronous programming patterns.
|
KafkaFuture.BaseFunction<A,B> |
A function which takes objects of type A and returns objects of type B.
|
KafkaFuture.BiConsumer<A,B> |
A consumer of two different types of object.
|
KafkaFuture.Function<A,B> |
A function which takes objects of type A and returns objects of type B.
|
KafkaPrincipal |
Principals in Kafka are defined by a type and a name.
|
KafkaPrincipalBuilder |
|
KafkaProducer<K,V> |
A Kafka client that publishes records to the Kafka cluster.
|
KafkaStorageException |
Miscellaneous disk-related IOException occurred when handling a request.
|
KafkaStreams |
A Kafka client that allows for performing continuous computation on input coming from one or more input topics and
sends output to zero, one, or more output topics.
|
KafkaStreams.State |
Kafka Streams states are the possible state that a Kafka Streams instance can be in.
|
KafkaStreams.StateListener |
|
KafkaStreamsInternalStorageInitializer |
|
KeyQueryMetadata |
Represents all the metadata related to a key, where a particular key resides in a KafkaStreams application.
|
KeyValue<K,V> |
A key-value pair defined for a single Kafka Streams record.
|
KeyValueBytesStoreSupplier |
|
KeyValueIterator<K,V> |
|
KeyValueIteratorFacade<K,V> |
|
KeyValueMapper<K,V,VR> |
The KeyValueMapper interface for mapping a key-value pair to a new value of arbitrary type.
|
KeyValueStore<K,V> |
A key-value store that supports put/get/delete and range queries.
|
KeyValueStoreBuilder<K,V> |
|
KeyValueStoreFacade<K,V> |
|
KeyValueToTimestampedKeyValueByteStoreAdapter |
|
KGroupedStream<K,V> |
KGroupedStream is an abstraction of a grouped record stream of KeyValue pairs.
|
KGroupedTable<K,V> |
KGroupedTable is an abstraction of a re-grouped changelog stream from a primary-keyed table,
usually on a different grouping key than the original primary key.
|
KGroupedTableImpl<K,V> |
|
KStream<K,V> |
KStream is an abstraction of a record stream of KeyValue pairs, i.e., each record is an
independent entity/event in the real world.
|
KStreamAggProcessorSupplier<K,RK,V,T> |
|
KStreamAggregate<K,V,T> |
|
KStreamFlatTransform<KIn,VIn,KOut,VOut> |
|
KStreamFlatTransform.KStreamFlatTransformProcessor<KIn,VIn,KOut,VOut> |
|
KStreamFlatTransformValues<KIn,VIn,VOut> |
|
KStreamFlatTransformValues.KStreamFlatTransformValuesProcessor<KIn,VIn,VOut> |
|
KStreamImpl<K,V> |
|
KStreamPrint<K,V> |
|
KStreamReduce<K,V> |
|
KStreamSessionWindowAggregate<K,V,Agg> |
|
KStreamTransformValues<K,V,R> |
|
KStreamTransformValues.KStreamTransformValuesProcessor<K,V,R> |
|
KStreamWindowAggregate<K,V,Agg,W extends Window> |
|
KTable<K,V> |
KTable is an abstraction of a changelog stream from a primary-keyed table.
|
KTableAggregate<K,V,T> |
|
KTableImpl<K,S,V> |
The implementation class of KTable .
|
KTableKTableAbstractJoinValueGetterSupplier<K,R,V1,V2> |
|
KTableKTableJoinMerger<K,V> |
|
KTableKTableJoinNode<K,V1,V2,VR> |
Too much specific information to generalize so the KTable-KTable join requires a specific node.
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
|
KTableMaterializedValueGetterSupplier<K,V> |
|
KTableProcessorSupplier<K,V,T> |
|
KTableReduce<K,V> |
|
KTableRepartitionMap<K,V,K1,V1> |
KTable repartition map functions are not exposed to public APIs, but only used for keyed aggregations.
|
KTableSource<K,V> |
|
KTableSourceValueGetterSupplier<K,V> |
|
KTableSuppressProcessorSupplier<K,V> |
|
KTableValueGetter<K,V> |
|
KTableValueGetterSupplier<K,V> |
|
LagInfo |
Encapsulates information about lag, at a store partition replica (active or standby).
|
LeaderNotAvailableException |
There is no currently available leader for the given partition (either because a leadership election is in progress
or because all replicas are down).
|
ListConsumerGroupOffsetsOptions |
|
ListConsumerGroupOffsetsResult |
|
ListConsumerGroupsOptions |
|
ListConsumerGroupsResult |
|
ListenerNotFoundException |
The leader does not have an endpoint corresponding to the listener on which metadata was requested.
|
ListOffsetsOptions |
|
ListOffsetsResult |
|
ListOffsetsResult.ListOffsetsResultInfo |
|
ListPartitionReassignmentsOptions |
|
ListPartitionReassignmentsResult |
|
ListTopicsOptions |
|
ListTopicsResult |
|
LockException |
Indicates that the state store directory lock could not be acquired because another thread holds the lock.
|
LogAndContinueExceptionHandler |
Deserialization handler that logs a deserialization exception and then
signals the processing pipeline to continue processing more records.
|
LogAndFailExceptionHandler |
Deserialization handler that logs a deserialization exception and then
signals the processing pipeline to stop processing more records and fail.
|
LogAndSkipOnInvalidTimestamp |
Retrieves embedded metadata timestamps from Kafka messages.
|
LogDirNotFoundException |
Thrown when a request is made for a log directory that is not present on the broker
|
Login |
Login interface for authentication.
|
LogLevelConfig |
This class holds definitions for log level configurations related to Kafka's application logging.
|
LogTruncationException |
In the event of an unclean leader election, the log will be truncated,
previously committed data will be lost, and new data will be written
over these offsets.
|
LongDeserializer |
|
LongSerializer |
|
Materialized<K,V,S extends StateStore> |
Used to describe how a StateStore should be materialized.
|
MaterializedInternal<K,V,S extends StateStore> |
|
Maybe<T> |
A container that may be empty, may contain null, or may contain a value.
|
MemberAssignment |
A description of the assignments of a specific group member.
|
MemberDescription |
A detailed description of a single group instance in the cluster.
|
MemberIdRequiredException |
|
MemberToRemove |
A struct containing information about the member to be removed.
|
MemoryLRUCache |
An in-memory LRU cache store based on HashSet and HashMap.
|
MemoryLRUCache.EldestEntryRemovalListener |
|
MemoryNavigableLRUCache |
|
Merger<K,V> |
The interface for merging aggregate values for SessionWindows with the given key.
|
MeteredKeyValueStore<K,V> |
A Metered KeyValueStore wrapper that is used for recording operation metrics, and hence its
inner KeyValueStore implementation do not need to provide its own metrics collecting functionality.
|
MeteredSessionStore<K,V> |
|
MeteredTimestampedKeyValueStore<K,V> |
A Metered TimestampedKeyValueStore wrapper that is used for recording operation metrics, and hence its
inner KeyValueStore implementation do not need to provide its own metrics collecting functionality.
|
MeteredTimestampedKeyValueStore.RawAndDeserializedValue<ValueType> |
|
MeteredWindowStore<K,V> |
|
Metric |
A metric tracked for monitoring purposes.
|
MetricName |
The MetricName class encapsulates a metric's name, logical group and its related attributes.
|
MetricNameTemplate |
A template for a MetricName.
|
MirrorClient |
Interprets MM2's internal topics (checkpoints, heartbeats) on a given cluster.
|
MirrorClientConfig |
Configuration required for MirrorClient to talk to a given target cluster.
|
MockConsumer<K,V> |
This class is not supported.
|
MockProcessorContext |
|
MockProcessorContext.CapturedForward |
|
MockProcessorContext.CapturedPunctuator |
|
MockProducer<K,V> |
This class is not supported.
|
Murmur3 |
This class was taken from Hive org.apache.hive.common.util;
https://github.com/apache/hive/blob/master/storage-api/src/java/org/apache/hive/common/util/Murmur3.java
Commit: dffa3a16588bc8e95b9d0ab5af295a74e06ef702
Murmur3 is successor to Murmur2 fast non-crytographic hash algorithms.
|
Murmur3.IncrementalHash32 |
|
Named |
|
NamedCacheMetrics |
|
NamedInternal |
|
NamedSuppressed<K> |
Internally-facing interface to work around the fact that all Suppressed config objects
are name-able, but do not present a getter (for consistency with other config objects).
|
NetworkException |
A misc.
|
NewPartitionReassignment |
|
NewPartitions |
|
NewTopic |
|
Node |
Information about a Kafka node
|
NoOffsetForPartitionException |
Indicates that there is no stored offset for a partition and no defined offset
reset policy.
|
NoReassignmentInProgressException |
Thrown if a reassignment cannot be cancelled because none is in progress.
|
NotControllerException |
|
NotCoordinatorException |
In the context of the group coordinator, the broker returns this error code if it receives an offset fetch
or commit request for a group it's not the coordinator of.
|
NotEnoughReplicasAfterAppendException |
Number of insync replicas for the partition is lower than min.insync.replicas This exception is raised when the low
ISR size is discovered *after* the message was already appended to the log.
|
NotEnoughReplicasException |
Number of insync replicas for the partition is lower than min.insync.replicas
|
NotFoundException |
Indicates that an operation attempted to modify or delete a connector or task that is not present on the worker.
|
NotLeaderForPartitionException |
Deprecated.
|
NotLeaderOrFollowerException |
Broker returns this error if a request could not be processed because the broker is not the leader
or follower for a topic partition.
|
OAuthBearerExtensionsValidatorCallback |
A Callback for use by the SaslServer implementation when it
needs to validate the SASL extensions for the OAUTHBEARER mechanism
Callback handlers should use the OAuthBearerExtensionsValidatorCallback.valid(String)
method to communicate valid extensions back to the SASL server.
|
OAuthBearerLoginModule |
The LoginModule for the SASL/OAUTHBEARER mechanism.
|
OAuthBearerToken |
The b64token value as defined in
RFC 6750 Section
2.1 along with the token's specific scope and lifetime and principal
name.
|
OAuthBearerTokenCallback |
A Callback for use by the SaslClient and Login
implementations when they require an OAuth 2 bearer token.
|
OAuthBearerValidatorCallback |
A Callback for use by the SaslServer implementation when it
needs to provide an OAuth 2 bearer token compact serialization for
validation.
|
OffsetAndMetadata |
The Kafka offset commit API allows users to provide additional metadata (in the form of a string)
when an offset is committed.
|
OffsetAndTimestamp |
A container class for offset and timestamp.
|
OffsetCheckpoint |
This class saves out a map of topic/partition=>offsets to a file.
|
OffsetCommitCallback |
A callback interface that the user can implement to trigger custom actions when a commit request completes.
|
OffsetMetadataTooLarge |
The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server.
|
OffsetNotAvailableException |
Indicates that the leader is not able to guarantee monotonically increasing offsets
due to the high watermark lagging behind the epoch start offset after a recent leader election
|
OffsetOutOfRangeException |
No reset policy has been defined, and the offsets for these partitions are either larger or smaller
than the range of offsets the server has for the given partition.
|
OffsetOutOfRangeException |
No reset policy has been defined, and the offsets for these partitions are either larger or smaller
than the range of offsets the server has for the given partition.
|
OffsetResetStrategy |
|
OffsetSpec |
|
OffsetSpec.EarliestSpec |
|
OffsetSpec.LatestSpec |
|
OffsetSpec.TimestampSpec |
|
OffsetStorageReader |
OffsetStorageReader provides access to the offset storage used by sources.
|
OperationNotAttemptedException |
Indicates that the broker did not attempt to execute this operation.
|
OptimizableRepartitionNode<K,V> |
|
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
|
OutOfOrderSequenceException |
This exception indicates that the broker received an unexpected sequence number from the producer,
which means that data may have been lost.
|
OutputVerifier |
Deprecated.
|
Partitioner |
Partitioner Interface is not supported.
|
PartitionGroup |
PartitionGroup is used to buffer all co-partitioned records for processing.
|
PartitionGrouper |
Deprecated.
|
PartitionInfo |
This is used to describe per-partition state in the MetadataResponse.
|
PartitionReassignment |
|
PatternType |
Resource pattern type.
|
PeekingKeyValueIterator<K,V> |
|
PlainAuthenticateCallback |
|
PlainLoginModule |
|
PlaintextAuthenticationContext |
|
PolicyViolationException |
Exception thrown if a create topics request does not satisfy the configured policy for a topic.
|
Predicate<R extends ConnectRecord<R>> |
A predicate on records.
|
Predicate<K,V> |
The Predicate interface represents a predicate (boolean-valued function) of a KeyValue pair.
|
PreferredLeaderNotAvailableException |
|
PrincipalBuilder |
Deprecated.
|
Printed<K,V> |
An object to define the options used when printing a KStream .
|
PrintedInternal<K,V> |
|
PrintForeachAction<K,V> |
|
Processor<K,V> |
A processor of key-value pair records.
|
ProcessorContext |
Processor context interface.
|
ProcessorContextImpl |
|
ProcessorContextUtils |
This class bridges the gap for components that _should_ be compatible with
the public ProcessorContext interface, but have come to depend on features
in InternalProcessorContext.
|
ProcessorGraphNode<K,V> |
Used to represent any type of stateless operation:
map, mapValues, flatMap, flatMapValues, filter, filterNot, branch
|
ProcessorNode<K,V> |
|
ProcessorNodeMetrics |
|
ProcessorNodePunctuator |
|
ProcessorParameters<K,V> |
Class used to represent a ProcessorSupplier and the name
used to register it with the InternalTopologyBuilder
Used by the Join nodes as there are several parameters, this abstraction helps
keep the number of arguments more reasonable.
|
ProcessorRecordContext |
|
ProcessorStateException |
Indicates a processor state operation (e.g.
|
ProcessorStateManager |
ProcessorStateManager is the source of truth for the current offset for each state store,
which is either the read offset during restoring, or the written offset during normal processing.
|
ProcessorStateManager.StateStoreMetadata |
|
ProcessorSupplier<K,V> |
A processor supplier that can create one or more Processor instances.
|
ProcessorTopology |
|
Produced<K,V> |
|
ProducedInternal<K,V> |
|
Producer<K,V> |
|
ProducerConfig |
Configuration for the Kafka Producer.
|
ProducerFencedException |
This fatal exception indicates that another producer with the same transactional.id has been
started.
|
ProducerInterceptor<K,V> |
A plugin interface that allows you to intercept (and possibly mutate) the records received by the producer before
they are published to the Kafka cluster.
|
ProducerRecord<K,V> |
A key/value pair to be sent to Kafka.
|
ProductionExceptionHandler |
Interface that specifies how an exception when attempting to produce a result to
Kafka should be handled.
|
ProductionExceptionHandler.ProductionExceptionHandlerResponse |
|
PunctuationQueue |
|
PunctuationSchedule |
|
PunctuationType |
|
Punctuator |
|
QueryableStoreProvider |
|
QueryableStoreType<T> |
|
QueryableStoreTypes |
|
QueryableStoreTypes.KeyValueStoreType<K,V> |
|
QueryableStoreTypes.SessionStoreType<K,V> |
|
QueryableStoreTypes.WindowStoreType<K,V> |
|
QuickUnion<T> |
|
QuietStreamsConfig |
A StreamsConfig that does not log its configuration on construction.
|
RangeAssignor |
This class is not supported.
|
ReadOnlyKeyValueStore<K,V> |
A key-value store that only supports read operations.
|
ReadOnlyKeyValueStoreFacade<K,V> |
|
ReadOnlySessionStore<K,AGG> |
A session store that only supports read operations.
|
ReadOnlyWindowStore<K,V> |
A window store that only supports read operations.
|
ReadOnlyWindowStoreFacade<K,V> |
|
ReassignmentInProgressException |
Thrown if a request cannot be completed because a partition reassignment is in progress.
|
RebalanceInProgressException |
|
Reconfigurable |
Interface for reconfigurable classes that support dynamic configuration.
|
RecordBatchingStateRestoreCallback |
|
RecordBatchTooLargeException |
This record batch is larger than the maximum allowable size
|
RecordCollector |
|
RecordCollector.Supplier |
|
RecordCollectorImpl |
|
RecordContext |
The context associated with the current record being processed by
an Processor
|
RecordConverter |
|
RecordConverters |
|
RecordMetadata |
The metadata for a record that has been acknowledged by the server
|
RecordQueue |
RecordQueue is a FIFO queue of StampedRecord (ConsumerRecord + timestamp).
|
RecordsToDelete |
|
RecordTooLargeException |
This record is larger than the maximum allowable size
|
Reducer<V> |
The Reducer interface for combining two values of the same type into a new value.
|
RemoteClusterUtils |
Convenience methods for multi-cluster environments.
|
RemoveMembersFromConsumerGroupOptions |
|
RemoveMembersFromConsumerGroupResult |
|
RenewDelegationTokenOptions |
|
RenewDelegationTokenResult |
|
Repartitioned<K,V> |
This class is used to provide the optional parameters for internal repartition topics.
|
RepartitionedInternal<K,V> |
|
RepartitionTopicConfig |
RepartitionTopicConfig captures the properties required for configuring
the repartition topics.
|
ReplicaNotAvailableException |
The replica is not available for the requested topic partition.
|
ReplicationPolicy |
Defines which topics are "remote topics".
|
Resource |
Represents a cluster resource with a tuple of (type, name).
|
ResourceFilter |
A filter which matches Resource objects.
|
ResourcePattern |
Represents a pattern that is used by ACLs to match zero or more
Resources .
|
ResourcePatternFilter |
|
ResourceType |
Represents a type of resource which an ACL can be applied to.
|
RestoringTasks |
|
RetriableCommitFailedException |
|
RetriableException |
A retryable exception is a transient exception that if retried may succeed.
|
RetriableException |
An exception that indicates the operation can be reattempted.
|
RocksDBConfigSetter |
An interface to that allows developers to customize the RocksDB settings for a given Store.
|
RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter |
The generic Options class allows users to set all configs on one object if only default column family
is used.
|
RocksDbKeyValueBytesStoreSupplier |
|
RocksDBMetrics |
|
RocksDBMetrics.RocksDBMetricContext |
|
RocksDBMetricsRecorder |
|
RocksDBMetricsRecordingTrigger |
|
RocksDBSegmentedBytesStore |
|
RocksDbSessionBytesStoreSupplier |
|
RocksDBSessionStore |
|
RocksDBStore |
A persistent key-value store based on RocksDB.
|
RocksDBTimestampedSegmentedBytesStore |
|
RocksDBTimestampedStore |
A persistent key-(value-timestamp) store based on RocksDB.
|
RocksDbWindowBytesStoreSupplier |
|
RocksDBWindowStore |
|
RoundRobinAssignor |
This class is not supported.
|
RoundRobinPartitioner |
The "Round-Robin" partitioner
This partitioning strategy can be used when user wants
to distribute the writes to all partitions equally.
|
SaslAuthenticationContext |
|
SaslAuthenticationException |
This exception indicates that SASL authentication has failed.
|
SaslConfigs |
|
SaslExtensions |
A simple immutable value object class holding customizable SASL extensions
|
SaslExtensionsCallback |
Optional callback used for SASL mechanisms if any extensions need to be set
in the SASL exchange.
|
Schema |
Definition of an abstract data type.
|
Schema.Type |
The type of a schema.
|
SchemaAndValue |
|
SchemaBuilder |
SchemaBuilder provides a fluent API for constructing Schema objects.
|
SchemaBuilderException |
|
SchemaProjector |
SchemaProjector is utility to project a value between compatible schemas and throw exceptions
when non compatible schemas are provided.
|
SchemaProjectorException |
|
ScramCredential |
SCRAM credential class that encapsulates the credential data persisted for each user that is
accessible to the server.
|
ScramCredentialCallback |
Callback used for SCRAM mechanisms.
|
ScramExtensionsCallback |
Optional callback used for SCRAM mechanisms if any extensions need to be set
in the SASL/SCRAM exchange.
|
ScramLoginModule |
|
SecurityConfig |
Contains the common security config for SSL and SASL
|
SecurityDisabledException |
An error indicating that security is disabled on the broker.
|
SecurityProtocol |
|
SecurityProviderCreator |
An interface for generating security providers.
|
Segment |
|
SegmentedBytesStore |
The interface representing a StateStore that has 1 or more segments that are based
on time.
|
SegmentedBytesStore.KeySchema |
|
Serde<T> |
The interface for wrapping a serializer and deserializer for the given data type.
|
Serdes |
Factory for creating serializers / deserializers.
|
Serdes.ByteArraySerde |
|
Serdes.ByteBufferSerde |
|
Serdes.BytesSerde |
|
Serdes.DoubleSerde |
|
Serdes.FloatSerde |
|
Serdes.IntegerSerde |
|
Serdes.LongSerde |
|
Serdes.ShortSerde |
|
Serdes.StringSerde |
|
Serdes.UUIDSerde |
|
Serdes.VoidSerde |
|
Serdes.WrapperSerde<T> |
|
SerializationException |
Any exception during serialization in the producer
|
Serialized<K,V> |
Deprecated.
|
SerializedInternal<K,V> |
Deprecated. |
Serializer<T> |
An interface for converting objects to bytes.
|
SessionBytesStoreSupplier |
|
SessionKeySchema |
|
SessionStore<K,AGG> |
Interface for storing the aggregated values of sessions.
|
SessionStoreBuilder<K,V> |
|
SessionWindow |
A session window covers a closed time interval with its start and end timestamp both being an inclusive boundary.
|
SessionWindowedCogroupedKStream<K,V> |
SessionWindowedCogroupKStream is an abstraction of a windowed record stream of KeyValue pairs.
|
SessionWindowedCogroupedKStreamImpl<K,V> |
|
SessionWindowedDeserializer<T> |
|
SessionWindowedKStream<K,V> |
SessionWindowedKStream is an abstraction of a windowed record stream of KeyValue pairs.
|
SessionWindowedKStreamImpl<K,V> |
|
SessionWindowedSerializer<T> |
|
SessionWindows |
A session based window specification used for aggregating events into sessions.
|
ShortDeserializer |
|
ShortSerializer |
|
SimpleHeaderConverter |
A HeaderConverter that serializes header values as strings and that deserializes header values to the most appropriate
numeric, boolean, array, or map representation.
|
SinkConnector |
SinkConnectors implement the Connector interface to send Kafka data to another system.
|
SinkConnectorContext |
A context to allow a SinkConnector to interact with the Kafka Connect runtime.
|
SinkNode<K,V> |
|
SinkRecord |
SinkRecord is a ConnectRecord that has been read from Kafka and includes the kafkaOffset of
the record in the Kafka topic-partition in addition to the standard fields.
|
SinkTask |
SinkTask is a Task that takes records loaded from Kafka and sends them to another system.
|
SinkTaskContext |
Context passed to SinkTasks, allowing them to access utilities in the Kafka Connect runtime.
|
SourceAndTarget |
Directional pair of clustes, where source is replicated to target.
|
SourceConnector |
SourceConnectors implement the connector interface to pull data from another system and send
it to Kafka.
|
SourceConnectorContext |
A context to allow a SourceConnector to interact with the Kafka Connect runtime.
|
SourceNode<K,V> |
|
SourceRecord |
SourceRecords are generated by SourceTasks and passed to Kafka Connect for storage in
Kafka.
|
SourceTask |
SourceTask is a Task that pulls records from another system for storage in Kafka.
|
SourceTaskContext |
SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying
runtime.
|
SslAuthenticationContext |
|
SslAuthenticationException |
This exception indicates that SSL handshake has failed.
|
SslClientAuth |
Describes whether the server should require or request client authentication.
|
SslConfigs |
|
SslEngineFactory |
Plugin interface for allowing creation of SSLEngine object in a custom way.
|
StaleBrokerEpochException |
|
Stamped<V> |
|
StampedRecord |
|
StandbyTask |
A StandbyTask
|
StateDirectory |
Manages the directories where the state of Tasks owned by a StreamThread are
stored.
|
StatefulProcessorNode<K,V> |
|
StateRestoreCallback |
Restoration logic for log-backed state stores upon restart,
it takes one record at a time from the logs to apply to the restoring state.
|
StateRestoreCallbackAdapter |
|
StateRestoreListener |
Class for listening to various states of the restoration process of a StateStore.
|
StateSerdes<K,V> |
Factory for creating serializers / deserializers for state stores in Kafka Streams.
|
StateStore |
A storage engine for managing state maintained by a stream processor.
|
StateStoreMetrics |
|
StateStoreNode<S extends StateStore> |
|
StateStoreProvider |
|
StaticTopicNameExtractor<K,V> |
Static topic name extractor
|
StickyAssignor |
This class is not supported.
|
StickyTaskAssignor |
|
StoreBuilder<T extends StateStore> |
Build a StateStore wrapped with optional caching and logging.
|
StoreChangelogReader |
ChangelogReader is created and maintained by the stream thread and used for both updating standby tasks and
restoring active tasks.
|
StoreQueryParameters<T> |
StoreQueryParameters allows you to pass a variety of parameters when fetching a store for interactive query.
|
Stores |
Factory for creating state stores in Kafka Streams.
|
StoreSupplier<T extends StateStore> |
A state store supplier which can create one or more StateStore instances.
|
StreamJoined<K,V1,V2> |
Class used to configure the name of the join processor, the repartition topic name,
state stores or state store names in Stream-Stream join.
|
StreamJoinedInternal<K,V1,V2> |
|
StreamPartitioner<K,V> |
Determine how records are distributed among the partitions in a Kafka topic.
|
StreamsAssignmentProtocolVersions |
|
StreamsBuilder |
StreamsBuilder provide the high-level Kafka Streams DSL to specify a Kafka Streams topology.
|
StreamsConfig |
|
StreamsConfig.InternalConfig |
|
StreamsException |
|
StreamsGraphNode |
|
StreamSinkNode<K,V> |
|
StreamsMetadata |
Represents the state of an instance (process) in a KafkaStreams application.
|
StreamsMetadataState |
|
StreamsMetrics |
The Kafka Streams metrics interface for adding metric sensors and collecting metric values.
|
StreamsMetricsImpl |
|
StreamsMetricsImpl.Version |
|
StreamSourceNode<K,V> |
|
StreamsPartitionAssignor |
|
StreamsPartitioner |
Partitioner Interface
|
StreamsProducer |
StreamsProducer manages the producers within a Kafka Streams application.
|
StreamsRebalanceListener |
|
StreamStreamJoinNode<K,V1,V2,VR> |
Too much information to generalize, so Stream-Stream joins are represented by a specific node.
|
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> |
|
StreamTableJoinNode<K,V> |
Represents a join between a KStream and a KTable or GlobalKTable
|
StreamTask |
A StreamTask is associated with a PartitionGroup , and is assigned to a StreamThread for processing.
|
StreamThread |
|
StreamThread.ProcessingMode |
|
StreamThread.State |
Stream thread states are the possible states that a stream thread can be in.
|
StreamThread.StateListener |
Listen to state change events
|
StreamThreadStateStoreProvider |
|
StreamToTableNode<K,V> |
Represents a KTable convert From KStream
|
StrictBufferConfigImpl |
|
StringConverter |
|
StringConverterConfig |
|
StringDeserializer |
String encoding defaults to UTF8 and can be customized by setting the property key.deserializer.encoding,
value.deserializer.encoding or deserializer.encoding.
|
StringSerializer |
String encoding defaults to UTF8 and can be customized by setting the property key.serializer.encoding,
value.serializer.encoding or serializer.encoding.
|
Struct |
A structured record containing a set of named fields with values, each field using an independent Schema .
|
SubscriptionInfo |
|
SubscriptionInfoData |
|
SubscriptionInfoData.PartitionToOffsetSum |
|
SubscriptionInfoData.TaskId |
|
SubscriptionInfoData.TaskOffsetSum |
|
SubscriptionJoinForeignProcessorSupplier<K,KO,VO> |
Receives SubscriptionWrapper<K> events and processes them according to their Instruction.
|
SubscriptionResolverJoinProcessorSupplier<K,V,VO,VR> |
Receives SubscriptionResponseWrapper<VO> events and filters out events which do not match the current hash
of the primary key.
|
SubscriptionResponseWrapper<FV> |
|
SubscriptionResponseWrapperSerde<V> |
|
SubscriptionStoreReceiveProcessorSupplier<K,KO> |
|
SubscriptionWrapper<K> |
|
SubscriptionWrapper.Instruction |
|
SubscriptionWrapperSerde<K> |
|
Suppressed<K> |
|
Suppressed.BufferConfig<BC extends Suppressed.BufferConfig<BC>> |
|
Suppressed.EagerBufferConfig |
Marker interface for a buffer configuration that will strictly enforce size constraints
(bytes and/or number of records) on the buffer, so it is suitable for reducing duplicate
results downstream, but does not promise to eliminate them entirely.
|
Suppressed.StrictBufferConfig |
Marker interface for a buffer configuration that is "strict" in the sense that it will strictly
enforce the time bound and never emit early.
|
SuppressedInternal<K> |
|
TableProcessorNode<K,V> |
|
TableSourceNode<K,V> |
Used to represent either a KTable source or a GlobalKTable source.
|
TableSourceNode.TableSourceNodeBuilder<K,V> |
|
Task |
Tasks contain the code that actually copies data to/from another system.
|
Task |
|
Task.State |
|
Task.TaskType |
|
TaskAssignmentException |
|
TaskAssignor |
|
TaskCorruptedException |
Indicates a specific task is corrupted and need to be re-initialized.
|
TaskId |
The task ID representation composed as topic group ID plus the assigned partition ID.
|
TaskIdFormatException |
Indicates a run time error incurred while trying parse the task id
from the read string.
|
TaskManager |
|
TaskMetadata |
Represents the state of a single task running within a KafkaStreams application.
|
TaskMetrics |
|
TaskMigratedException |
Indicates that all tasks belongs to the thread have migrated to another thread.
|
TaskState |
Describes the state, IDs, and any errors of a connector task.
|
TestDriverProducer |
|
TestInputTopic<K,V> |
|
TestOutputTopic<K,V> |
|
TestRecord<K,V> |
A key/value pair, including timestamp and record headers, to be sent to or received from TopologyTestDriver .
|
ThreadCache |
An in-memory LRU cache store similar to MemoryLRUCache but byte-based, not
record based
|
ThreadCache.DirtyEntryFlushListener |
|
ThreadMetadata |
Represents the state of a single thread running within a KafkaStreams application.
|
ThreadMetrics |
|
ThreadStateTransitionValidator |
Basic interface for keeping track of the state of a thread.
|
Time |
A time representing a specific point in a day, not tied to any specific date.
|
TimeOrderedKeyValueBuffer<K,V> |
|
TimeOrderedKeyValueBuffer.Eviction<K,V> |
|
TimeoutException |
Indicates that a request timed out.
|
Timestamp |
A timestamp representing an absolute time, without timezone information.
|
TimestampedBytesStore |
|
TimestampedKeyValueStore<K,V> |
A key-(value/timestamp) store that supports put/get/delete and range queries.
|
TimestampedKeyValueStoreBuilder<K,V> |
|
TimestampedKeyValueStoreMaterializer<K,V> |
|
TimestampedWindowStore<K,V> |
Interface for storing the aggregated values of fixed-size time windows.
|
TimestampedWindowStoreBuilder<K,V> |
|
TimestampExtractor |
An interface that allows the Kafka Streams framework to extract a timestamp from an instance of ConsumerRecord .
|
TimeWindow |
A TimeWindow covers a half-open time interval with its start timestamp as an inclusive boundary and its end
timestamp as exclusive boundary.
|
TimeWindowedCogroupedKStream<K,V> |
TimeWindowedCogroupKStream is an abstraction of a windowed record stream of KeyValue pairs.
|
TimeWindowedCogroupedKStreamImpl<K,V,W extends Window> |
|
TimeWindowedDeserializer<T> |
|
TimeWindowedKStream<K,V> |
TimeWindowedKStream is an abstraction of a windowed record stream of KeyValue pairs.
|
TimeWindowedKStreamImpl<K,V,W extends Window> |
|
TimeWindowedSerializer<T> |
|
TimeWindows |
The fixed-size time-based window specifications used for aggregations.
|
To |
|
ToInternal |
|
TokenInformation |
A class representing a delegation token details.
|
TopicAuthorizationException |
|
TopicConfig |
Keys that can be used to configure a topic.
|
TopicDeletionDisabledException |
|
TopicDescription |
A detailed description of a single topic in the cluster.
|
TopicExistsException |
|
TopicListing |
A listing of a topic in the cluster.
|
TopicNameExtractor<K,V> |
An interface that allows to dynamically determine the name of the Kafka topic to send at the sink node of the topology.
|
TopicPartition |
A topic name and partition number
|
TopicPartitionInfo |
A class containing leadership, replicas and ISR information for a topic partition.
|
TopicPartitionReplica |
The topic name, partition number and the brokerId of the replica
|
Topology |
|
Topology.AutoOffsetReset |
|
TopologyDescription |
|
TopologyDescription.GlobalStore |
|
TopologyDescription.Node |
A node of a topology.
|
TopologyDescription.Processor |
A processor node of a topology.
|
TopologyDescription.Sink |
A sink node of a topology.
|
TopologyDescription.Source |
A source node of a topology.
|
TopologyDescription.Subtopology |
|
TopologyException |
|
TopologyTestDriver |
This class makes it easier to write tests to verify the behavior of topologies created with Topology or
StreamsBuilder .
|
TransactionalIdAuthorizationException |
|
TransactionCoordinatorFencedException |
|
Transformation<R extends ConnectRecord<R>> |
Single message transformation for Kafka Connect record types.
|
Transformer<K,V,R> |
The Transformer interface is for stateful mapping of an input record to zero, one, or multiple new output
records (both key and value type can be altered arbitrarily).
|
TransformerSupplier<K,V,R> |
A TransformerSupplier interface which can create one or more Transformer instances.
|
TransformerSupplierAdapter<KIn,VIn,KOut,VOut> |
|
UniformStickyPartitioner |
The partitioning strategy:
If a partition is specified in the record, use it
Otherwise choose the sticky partition that changes when the batch is full.
|
UnknownLeaderEpochException |
The request contained a leader epoch which is larger than that on the broker that received the
request.
|
UnknownMemberIdException |
|
UnknownProducerIdException |
This exception is raised by the broker if it could not locate the producer metadata associated with the producerId
in question.
|
UnknownServerException |
An error occurred on the server for which the client doesn't have a corresponding error code.
|
UnknownTopicOrPartitionException |
This topic/partition doesn't exist.
|
UnlimitedWindow |
UnlimitedWindow is an "infinite" large window with a fixed (inclusive) start time.
|
UnlimitedWindows |
The unlimited window specifications used for aggregations.
|
UnoptimizableRepartitionNode<K,V> |
Repartition node that is not subject of optimization algorithm
|
UnoptimizableRepartitionNode.UnoptimizableRepartitionNodeBuilder<K,V> |
|
UnstableOffsetCommitException |
Exception thrown when there are unstable offsets for the requested topic partitions.
|
UnsupportedByAuthenticationException |
Authentication mechanism does not support the requested function.
|
UnsupportedCompressionTypeException |
The requesting client does not support the compression type of given partition.
|
UnsupportedForMessageFormatException |
The message format version does not support the requested function.
|
UnsupportedSaslMechanismException |
This exception indicates that the SASL mechanism requested by the client
is not enabled on the broker.
|
UnsupportedVersionException |
Indicates that a request API or version needed by the client is not supported by the broker.
|
UnwindowedChangelogTopicConfig |
UnwindowedChangelogTopicConfig captures the properties required for configuring
the un-windowed store changelog topics.
|
UsePartitionTimeOnInvalidTimestamp |
Retrieves embedded metadata timestamps from Kafka messages.
|
UsePreviousTimeOnInvalidTimestamp |
Deprecated.
|
UUIDDeserializer |
We are converting the byte array to String before deserializing to UUID.
|
UUIDSerializer |
We are converting UUID to String before serializing.
|
ValueAndTimestamp<V> |
Combines a value from a KeyValue with a timestamp.
|
ValueAndTimestampSerde<V> |
|
ValueAndTimestampSerializer<V> |
|
ValueJoiner<V1,V2,VR> |
The ValueJoiner interface for joining two values into a new value of arbitrary type.
|
ValueMapper<V,VR> |
The ValueMapper interface for mapping a value to a new value of arbitrary type.
|
ValueMapperWithKey<K,V,VR> |
The ValueMapperWithKey interface for mapping a value to a new value of arbitrary type.
|
Values |
Utility for converting from one Connect value to a different form.
|
Values.Parser |
|
Values.SchemaDetector |
|
ValueTransformer<V,VR> |
The ValueTransformer interface for stateful mapping of a value to a new value (with possible new type).
|
ValueTransformerSupplier<V,VR> |
A ValueTransformerSupplier interface which can create one or more ValueTransformer instances.
|
ValueTransformerWithKey<K,V,VR> |
The ValueTransformerWithKey interface for stateful mapping of a value to a new value (with possible new type).
|
ValueTransformerWithKeySupplier<K,V,VR> |
|
Versioned |
Connect requires some components implement this interface to define a version string.
|
VoidDeserializer |
|
VoidSerializer |
|
WakeupException |
Exception used to indicate preemption of a blocking operation by an external thread.
|
WallclockTimestampExtractor |
|
Window |
A single window instance, defined by its start and end timestamp.
|
WindowBytesStoreSupplier |
|
Windowed<K> |
The result key type of a windowed stream aggregation.
|
WindowedChangelogTopicConfig |
WindowedChangelogTopicConfig captures the properties required for configuring
the windowed store changelog topics.
|
WindowedSerdes |
|
WindowedSerdes.SessionWindowedSerde<T> |
|
WindowedSerdes.TimeWindowedSerde<T> |
|
WindowedSerializer<T> |
|
WindowedStreamPartitioner<K,V> |
|
WindowingDefaults |
|
WindowKeySchema |
|
Windows<W extends Window> |
The window specification for fixed size windows that is used to define window boundaries and grace period.
|
WindowStore<K,V> |
Interface for storing the aggregated values of fixed-size time windows.
|
WindowStoreBuilder<K,V> |
|
WindowStoreFacade<K,V> |
|
WindowStoreIterator<V> |
|
WrappedStateStore<S extends StateStore,K,V> |
A storage engine wrapper for utilities like logging, caching, and metering.
|
WrappingNullableDeserializer<Outer,InnerK,InnerV> |
|
WrappingNullableSerde<T,InnerK,InnerV> |
|
WrappingNullableSerializer<Outer,InnerK,InnerV> |
|
WrappingNullableUtils |
If a component's serdes are Wrapping serdes, then they require a little extra setup
to be fully initialized at run time.
|
WrappingStoreProvider |
|