Kafka
- KafkaStart
Kafka.Admin
- ConfigCommand
- ConfigCommand.ConfigCommandOptions
Kafka.Tools
- DumpLogSegments
- StorageTool
- TestRaftServer
MASES.KNet
- CommonClientConfigsBuilder<T>
- Const
- GenericConfigBuilder<T>
- KNetCore<T>
MASES.KNet.Admin
- AdminClientConfigBuilder
MASES.KNet.CLI
- KNetCLICore<T>
MASES.KNet.Common
- TopicConfigBuilder
- TopicConfigBuilder.CleanupPolicyTypes
- TopicConfigBuilder.CompressionTypes
- TopicConfigBuilder.MessageTimestampTypes
MASES.KNet.Connect
- IConnector
- IKNetConnectLogging
- IKNetConnector
- IKNetTask
- ITask
- IVersion
- KNetConnectDistributed
- KNetConnectExtensions
- KNetConnectProxy
- KNetConnectStandalone
- KNetConnector
- KNetConnector<TConnector>
- KNetSinkConnector<TSinkConnector, TTask>
- KNetSinkTask<TTask>
- KNetSourceConnector<TSourceConnector, TTask>
- KNetSourceTask<TTask>
- KNetTask
- KNetTask<TTask>
MASES.KNet.Consumer
- ConsumerConfigBuilder
- ConsumerConfigBuilder.AutoOffsetResetTypes
- ConsumerRecord<K, V, TJVMK, TJVMV>
- ConsumerRecords<K, V, TJVMK, TJVMV>
- IConsumer<K, V, TJVMK, TJVMV>
- KNetConsumerBuffered<K, V>
- KNetConsumerKeyBuffered<K, V>
- KNetConsumerValueBuffered<K, V>
- KNetConsumer<K, V>
- KNetConsumer<K, V, TJVMK, TJVMV>
MASES.KNet.Extensions
- ConsumerConfigBuilderExtensions
- KafkaAdminClientExtensions
- KafkaConsumerExtensions
- KafkaProducerExtensions
- KafkaStreamsExtensions
- ProducerConfigBuilderExtensions
MASES.KNet.PowerShell
- KNetPSCore
- KNetPSHelper<TClass>
MASES.KNet.PowerShell.Cmdlet
- KNetPSCmdlet
- KafkaClassToRunCmdletCommandBase<TCmdlet>
- NewObjectCmdletCommand
- StartKNetPSCmdletCommand
- StartKNetPSCmdletCommandBase<TCmdlet>
MASES.KNet.PowerShell.Cmdlet.Client
- GetConsumerGroupMetadataCmdletCommand
- GetConsumerRecordCmdletCommand
- InvokePollCmdletCommand
- InvokeSendCmdletCommand
- InvokeSubscribeCmdletCommand
- InvokeUnsubscribeCmdletCommand
- NewAdminClientConfigBuilderCmdletCommand
- NewConsumerConfigBuilderCmdletCommand
- NewKNetConsumerCmdletCommand
- NewKNetProducerCmdletCommand
- NewKafkaAdminClientCmdletCommand
- NewKafkaConsumerCmdletCommand
- NewKafkaProducerCmdletCommand
- NewProducerConfigBuilderCmdletCommand
- NewProducerRecordCmdletCommand
MASES.KNet.PowerShell.Cmdlet.Tools
- AclCommandCmdletCommand
- BrokerApiVersionsCommandCmdletCommand
- ClusterToolCmdletCommand
- ConfigCommandCmdletCommand
- ConnectDistributedCmdletCommand
- ConnectStandaloneCmdletCommand
- ConsoleConsumerCmdletCommand
- ConsoleProducerCmdletCommand
- ConsumerGroupCommandCmdletCommand
- ConsumerPerformanceCmdletCommand
- DelegationTokenCommandCmdletCommand
- DeleteRecordsCommandCmdletCommand
- DumpLogSegmentsCmdletCommand
- FeatureCommandCmdletCommand
- GetOffsetShellCmdletCommand
- KafkaStartCmdletCommand
- LeaderElectionCommandCmdletCommand
- LogDirsCommandCmdletCommand
- MetadataQuorumCommandCmdletCommand
- MetadataShellCmdletCommand
- MirrorMaker2CmdletCommand
- MirrorMakerCmdletCommand
- ProducerPerformanceCmdletCommand
- ReassignPartitionsCommandCmdletCommand
- ReplicaVerificationToolCmdletCommand
- StorageToolCmdletCommand
- StreamsResetterCmdletCommand
- TopicCommandCmdletCommand
- TransactionsCommandCmdletCommand
- VerifiableConsumerCmdletCommand
- VerifiableProducerCmdletCommand
- ZkSecurityMigratorCmdletCommand
MASES.KNet.Producer
- IProducer<K, V, TJVMK, TJVMV>
- KNetProducerBuffered<K, V>
- KNetProducerKeyBuffered<K, V>
- KNetProducerValueBuffered<K, V>
- KNetProducer<K, V>
- KNetProducer<K, V, TJVMK, TJVMV>
- ProducerConfigBuilder
- ProducerConfigBuilder.AcksTypes
- ProducerConfigBuilder.CompressionTypes
- ProducerRecordBuffered<K, V>
- ProducerRecord<K, V>
- ProducerRecord<K, V, TJVMK, TJVMV>
MASES.KNet.Replicator
- AccessRightsType
- IKNetCompactedReplicator<K, V, TJVMK, TJVMV>
- KNetCompactedReplicatorBuffered<K, V>
- KNetCompactedReplicator<K, V>
- KNetCompactedReplicator<K, V, TJVMK, TJVMV>
- UpdateModeTypes
MASES.KNet.Serialization
- ByteBufferDeserializer
- ByteBufferSerializer
- DefaultSerDes<T>
- IDeserializer<T, TJVMT>
- IGenericSerDesFactory
- IGenericSerDesFactoryApplier
- ISerDes
- ISerDesBuffered<T>
- ISerDesRaw<T>
- ISerDesSelector
- ISerDesSelector<T>
- ISerDes<T, TJVMT>
- ISerializer<T, TJVMT>
- KNetSerialization
- KNetSerialization.SerializationType
- SerDes
- SerDesBuffered<T>
- SerDesRaw<T>
- SerDes<T, TJVMT>
- Serdes
- Serdes.ByteBufferSerde
MASES.KNet.Serialization.Avro
- AvroSerDes
- AvroSerDes.CompilerSupport
- AvroSerDes.Key
- AvroSerDes.Key.Binary<T>
- AvroSerDes.Key.Json<T>
- AvroSerDes.Value
- AvroSerDes.Value.Binary<T>
- AvroSerDes.Value.Json<T>
MASES.KNet.Serialization.Json
- JsonSerDes
- JsonSerDes.Key<T>
- JsonSerDes.Value<T>
MASES.KNet.Serialization.MessagePack
- MessagePackSerDes
- MessagePackSerDes.Key<T>
- MessagePackSerDes.Value<T>
MASES.KNet.Serialization.Protobuf
- ProtobufSerDes
- ProtobufSerDes.Key<T>
- ProtobufSerDes.Value<T>
MASES.KNet.Streams
- KNetClientSupplier
- KNetStreams
- KeyValueSupport<K, V>
- KeyValue<K, V, TJVMK, TJVMV>
- StreamsBuilder
- StreamsConfigBuilder
- TimestampedKeyValue<K, V, TJVMK, TJVMV>
- TimestampedWindowedKeyValue<K, V, TJVMK, TJVMV>
- Topology
- TopologyConfig
- WindowedKeyValue<K, V, TJVMK, TJVMV>
MASES.KNet.Streams.Kstream
- Aggregator<K, V, VA>
- Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>
- BranchedKStream<K, V, TJVMK, TJVMV>
- Branched<K, V, TJVMK, TJVMV>
- CogroupedKStream<K, VOut, TJVMK, TJVMVOut>
- Consumed<K, V, TJVMK, TJVMV>
- CountingMaterialized<K, TJVMK>
- EnumerableKeyValueMapper<K, V, KR, VR>
- EnumerableKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>
- EnumerableValueMapperWithKey<K, V, VR>
- EnumerableValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>
- EnumerableValueMapper<V, VR>
- EnumerableValueMapper<V, VR, TJVMV, TJVMVR>
- ForeachAction<K, V>
- ForeachAction<K, V, TJVMK, TJVMV>
- GlobalKTable<K, V, TJVMK, TJVMV>
- Grouped<K, V>
- Grouped<K, V, TJVMK, TJVMV>
- IKNetMaterialized<TJVMK, TJVMV>
- Initializer<VA>
- Initializer<VA, TJVMVA>
- Joined<K, V, VO>
- Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>
- KGroupedStream<K, V, TJVMK, TJVMV>
- KGroupedTable<K, V, TJVMK, TJVMV>
- KStream<K, V, TJVMK, TJVMV>
- KTable<K, V, TJVMK, TJVMV>
- KeyValueKeyValueMapper<K, V, KR, VR>
- KeyValueKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>
- KeyValueMapperForString<K, V>
- KeyValueMapperForString<K, V, TJVMK, TJVMV>
- KeyValueMapper<K, V, VR>
- KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
- Materialized<K, V, TJVMK>
- Materialized<K, V, TJVMK, TJVMV>
- Materialized<K, V, TJVMK, TJVMV, TContainer>
- Merger<K, V>
- Merger<K, V, TJVMK, TJVMV>
- PredicateEqualityTest<TKey, TValue>
- Predicate<K, V>
- Predicate<K, V, TJVMK, TJVMV>
- Printed<K, V>
- Printed<K, V, TJVMK, TJVMV>
- Produced<K, V>
- Produced<K, V, TJVMK, TJVMV>
- Reducer<V>
- Reducer<V, TJVMV>
- Repartitioned<K, V, TJVMK, TJVMV>
- SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
- SessionWindowedKStream<K, V, TJVMK, TJVMV>
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
- Suppressed<K>
- Suppressed<K, TJVMK>
- TableJoined<K, KO>
- TableJoined<K, KO, TJVMK, TJVMKO>
- TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
- TimeWindowedKStream<K, V, TJVMK, TJVMV>
- ValueJoinerWithKey<K1, V1, V2, VR>
- ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
- ValueJoiner<V1, V2, VR>
- ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>
- ValueMapperWithKey<K, V, VR>
- ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>
- ValueMapper<V, VR>
- ValueMapper<V, VR, TJVMV, TJVMVR>
- Windowed<K, TJVMK>
MASES.KNet.Streams.Processor
- StreamPartitionerNoValue<K>
- StreamPartitionerNoValue<K, TJVMK>
- StreamPartitioner<K, V>
- StreamPartitioner<K, V, TJVMK, TJVMV>
- TimestampExtractor<K, V, TJVMK, TJVMV>
- TopicNameExtractor<K, V>
- TopicNameExtractor<K, V, TJVMK, TJVMV>
MASES.KNet.Streams.Processor.Api
- ProcessorContext<KForward, VForward, TJVMKForward, TJVMVForward>
- Processor<KIn, VIn, KOut, VOut>
- Processor<KIn, VIn, KOut, VOut, TJVMKIn, TJVMVIn, TJVMKOut, TJVMVOut>
- Record<K, V, TJVMK, TJVMV>
MASES.KNet.Streams.State
- CommonIterator<TIteratorType>
- IManagedStore<TStore>
- KeyValueIterator<K, V, TJVMK, TJVMV>
- ManagedStore<TStore>
- QueryableStoreTypes
- QueryableStoreTypes.StoreType<TKNetManagedStore, TStore>
- ReadOnlyKeyValueStore<K, V>
- ReadOnlyKeyValueStore<K, V, TJVMK, TJVMV>
- ReadOnlySessionStore<K, AGG>
- ReadOnlySessionStore<K, AGG, TJVMK, TJVMAGG>
- ReadOnlyWindowStore<K, V>
- ReadOnlyWindowStore<K, V, TJVMK, TJVMV>
- TimestampedKeyValueIterator<K, V, TJVMK, TJVMV>
- TimestampedKeyValueStore<K, V>
- TimestampedKeyValueStore<K, V, TJVMK, TJVMV>
- TimestampedWindowStoreIterator<V, TJVMV>
- TimestampedWindowStore<K, V>
- TimestampedWindowStore<K, V, TJVMK, TJVMV>
- TimestampedWindowedKeyValueIterator<K, V, TJVMK, TJVMV>
- ValueAndTimestamp<V, TJVMV>
- WindowStoreIterator<V, TJVMV>
- WindowedKeyValueIterator<K, V, TJVMK, TJVMV>
MASES.KNet.Streams.Utils
- Function<V, KO>
- Function<V, KO, TJVMV, TJVMKO>
- KStreamConsumer<K, V>
- KStreamConsumer<K, V, TJVMK, TJVMV>
- KStreamFunction<K, V>
- KStreamFunction<K, V, TJVMK, TJVMV>
MASES.KNetTemplate.KNetConnect
- KNetConnectSink
- KNetConnectSinkTask
- KNetConnectSource
- KNetConnectSourceTask
Org.Apache.Kafka.Admin
- AdminUtils
- BrokerMetadata
Org.Apache.Kafka.Clients
- ApiVersions
- ApiVersions.FinalizedFeaturesInfo
- ClientDnsLookup
- ClientResponse
- ClientUtils
- CommonClientConfigs
- ConnectionState
- DefaultHostResolver
- GroupRebalanceConfig
- GroupRebalanceConfig.ProtocolType
- HostResolver
- IHostResolver
- IMetadataUpdater
- IRequestCompletionHandler
- LeastLoadedNode
- ManualMetadataUpdater
- Metadata
- Metadata.LeaderAndEpoch
- Metadata.LeaderIdAndEpoch
- Metadata.MetadataRequestAndVersion
- MetadataRecoveryStrategy
- MetadataSnapshot
- MetadataUpdater
- NetworkClientUtils
- NodeApiVersions
- RequestCompletionHandler
- StaleMetadataException
Org.Apache.Kafka.Clients.Admin
- AbortTransactionOptions
- AbortTransactionResult
- AbortTransactionSpec
- AbstractOptions
- AbstractOptions<T>
- AddRaftVoterOptions
- AddRaftVoterResult
- Admin
- AdminClient
- AdminClientConfig
- AlterClientQuotasOptions
- AlterClientQuotasResult
- AlterConfigOp
- AlterConfigOp.OpType
- AlterConfigsOptions
- AlterConfigsResult
- AlterConsumerGroupOffsetsOptions
- AlterConsumerGroupOffsetsResult
- AlterPartitionReassignmentsOptions
- AlterPartitionReassignmentsResult
- AlterReplicaLogDirsOptions
- AlterReplicaLogDirsResult
- AlterUserScramCredentialsOptions
- AlterUserScramCredentialsResult
- ClassicGroupDescription
- ClientMetricsResourceListing
- Config
- ConfigEntry
- ConfigEntry.ConfigSource
- ConfigEntry.ConfigSynonym
- ConfigEntry.ConfigType
- ConsumerGroupDescription
- ConsumerGroupListing
- CreateAclsOptions
- CreateAclsResult
- CreateDelegationTokenOptions
- CreateDelegationTokenResult
- CreatePartitionsOptions
- CreatePartitionsResult
- CreateTopicsOptions
- CreateTopicsResult
- CreateTopicsResult.TopicMetadataAndConfig
- DeleteAclsOptions
- DeleteAclsResult
- DeleteAclsResult.FilterResult
- DeleteAclsResult.FilterResults
- DeleteConsumerGroupOffsetsOptions
- DeleteConsumerGroupOffsetsResult
- DeleteConsumerGroupsOptions
- DeleteConsumerGroupsResult
- DeleteRecordsOptions
- DeleteRecordsResult
- DeleteTopicsOptions
- DeleteTopicsResult
- DeletedRecords
- DescribeAclsOptions
- DescribeAclsResult
- DescribeClassicGroupsOptions
- DescribeClassicGroupsResult
- DescribeClientQuotasOptions
- DescribeClientQuotasResult
- DescribeClusterOptions
- DescribeClusterResult
- DescribeConfigsOptions
- DescribeConfigsResult
- DescribeConsumerGroupsOptions
- DescribeConsumerGroupsResult
- DescribeDelegationTokenOptions
- DescribeDelegationTokenResult
- DescribeFeaturesOptions
- DescribeFeaturesResult
- DescribeLogDirsOptions
- DescribeLogDirsResult
- DescribeMetadataQuorumOptions
- DescribeMetadataQuorumResult
- DescribeProducersOptions
- DescribeProducersResult
- DescribeProducersResult.PartitionProducerState
- DescribeReplicaLogDirsOptions
- DescribeReplicaLogDirsResult
- DescribeReplicaLogDirsResult.ReplicaLogDirInfo
- DescribeShareGroupsOptions
- DescribeShareGroupsResult
- DescribeTopicsOptions
- DescribeTopicsResult
- DescribeTransactionsOptions
- DescribeTransactionsResult
- DescribeUserScramCredentialsOptions
- DescribeUserScramCredentialsResult
- ElectLeadersOptions
- ElectLeadersResult
- EndpointType
- ExpireDelegationTokenOptions
- ExpireDelegationTokenResult
- FeatureMetadata
- FeatureUpdate
- FeatureUpdate.UpgradeType
- FenceProducersOptions
- FenceProducersResult
- FinalizedVersionRange
- ForwardingAdmin
- GroupListing
- IAdmin
- KafkaAdminClient
- ListClientMetricsResourcesOptions
- ListClientMetricsResourcesResult
- ListConsumerGroupOffsetsOptions
- ListConsumerGroupOffsetsResult
- ListConsumerGroupOffsetsSpec
- ListConsumerGroupsOptions
- ListConsumerGroupsResult
- ListGroupsOptions
- ListGroupsResult
- ListOffsetsOptions
- ListOffsetsResult
- ListOffsetsResult.ListOffsetsResultInfo
- ListPartitionReassignmentsOptions
- ListPartitionReassignmentsResult
- ListTopicsOptions
- ListTopicsResult
- ListTransactionsOptions
- ListTransactionsResult
- LogDirDescription
- MemberAssignment
- MemberDescription
- MemberToRemove
- NewPartitionReassignment
- NewPartitions
- NewTopic
- OffsetSpec
- OffsetSpec.EarliestLocalSpec
- OffsetSpec.EarliestSpec
- OffsetSpec.LatestSpec
- OffsetSpec.LatestTieredSpec
- OffsetSpec.MaxTimestampSpec
- OffsetSpec.TimestampSpec
- PartitionReassignment
- ProducerState
- QuorumInfo
- QuorumInfo.Node
- QuorumInfo.ReplicaState
- RaftVoterEndpoint
- RecordsToDelete
- RemoveMembersFromConsumerGroupOptions
- RemoveMembersFromConsumerGroupResult
- RemoveRaftVoterOptions
- RemoveRaftVoterResult
- RenewDelegationTokenOptions
- RenewDelegationTokenResult
- ReplicaInfo
- ScramCredentialInfo
- ScramMechanism
- ShareGroupDescription
- ShareMemberAssignment
- ShareMemberDescription
- SupportedVersionRange
- TopicDescription
- TopicListing
- TransactionDescription
- TransactionListing
- TransactionState
- UnregisterBrokerOptions
- UnregisterBrokerResult
- UpdateFeaturesOptions
- UpdateFeaturesResult
- UserScramCredentialAlteration
- UserScramCredentialDeletion
- UserScramCredentialUpsertion
- UserScramCredentialsDescription
Org.Apache.Kafka.Clients.Consumer
- AcknowledgeType
- AcknowledgementCommitCallback
- CommitFailedException
- Consumer
- ConsumerConfig
- ConsumerGroupMetadata
- ConsumerInterceptor
- ConsumerInterceptorDirect
- ConsumerInterceptorDirect<K, V>
- ConsumerInterceptor<K, V>
- ConsumerPartitionAssignor
- ConsumerPartitionAssignor.Assignment
- ConsumerPartitionAssignor.GroupAssignment
- ConsumerPartitionAssignor.GroupSubscription
- ConsumerPartitionAssignor.RebalanceProtocol
- ConsumerPartitionAssignor.Subscription
- ConsumerPartitionAssignorDirect
- ConsumerRebalanceListener
- ConsumerRebalanceListenerDirect
- ConsumerRecord
- ConsumerRecord<K, V>
- ConsumerRecords
- ConsumerRecords<K, V>
- Consumer<K, V>
- CooperativeStickyAssignor
- GroupProtocol
- IAcknowledgementCommitCallback
- IConsumer
- IConsumerInterceptor<K, V>
- IConsumerPartitionAssignor
- IConsumerRebalanceListener
- IConsumer<K, V>
- IOffsetCommitCallback
- IShareConsumer<K, V>
- InvalidOffsetException
- KafkaConsumer
- KafkaConsumer<K, V>
- KafkaShareConsumer
- KafkaShareConsumer<K, V>
- LogTruncationException
- MockConsumer
- MockConsumer<K, V>
- MockShareConsumer
- MockShareConsumer<K, V>
- NoOffsetForPartitionException
- OffsetAndMetadata
- OffsetAndTimestamp
- OffsetCommitCallback
- OffsetCommitCallbackDirect
- OffsetOutOfRangeException
- RangeAssignor
- RetriableCommitFailedException
- RoundRobinAssignor
- ShareConsumer
- ShareConsumer<K, V>
- StickyAssignor
- SubscriptionPattern
Org.Apache.Kafka.Clients.Producer
- BufferExhaustedException
- Callback
- CallbackDirect
- ICallback
- IPartitioner
- IProducer
- IProducerInterceptor<K, V>
- IProducer<K, V>
- KafkaProducer
- KafkaProducer<K, V>
- MockProducer
- MockProducer<K, V>
- Partitioner
- PartitionerDirect
- Producer
- ProducerConfig
- ProducerInterceptor
- ProducerInterceptorDirect
- ProducerInterceptorDirect<K, V>
- ProducerInterceptor<K, V>
- ProducerRecord
- ProducerRecord<K, V>
- Producer<K, V>
- RecordMetadata
- RoundRobinPartitioner
Org.Apache.Kafka.Common
- ClassicGroupState
- ClientIdAndBroker
- Cluster
- ClusterResource
- ClusterResourceListener
- ClusterResourceListenerDirect
- Configurable
- DirectoryId
- ElectionType
- Endpoint
- GroupState
- GroupType
- IClusterResourceListener
- IConfigurable
- IMessageFormatter
- IMetric
- IReconfigurable
- InvalidRecordException
- IsolationLevel
- KafkaException
- KafkaFuture
- KafkaFuture.BaseFunction
- KafkaFuture.BaseFunction<A, B>
- KafkaFuture.BiConsumer
- KafkaFuture.BiConsumer<A, B>
- KafkaFuture<T>
- MessageFormatter
- Metric
- MetricName
- MetricNameTemplate
- Node
- PartitionInfo
- Reconfigurable
- TopicCollection
- TopicCollection.TopicIdCollection
- TopicCollection.TopicNameCollection
- TopicIdPartition
- TopicPartition
- TopicPartitionInfo
- TopicPartitionReplica
- Uuid
Org.Apache.Kafka.Common.Acl
- AccessControlEntry
- AccessControlEntryFilter
- AclBinding
- AclBindingFilter
- AclOperation
- AclPermissionType
Org.Apache.Kafka.Common.Annotation
- InterfaceStability
- InterfaceStability.Evolving
- InterfaceStability.Stable
- InterfaceStability.Unstable
Org.Apache.Kafka.Common.Cache
- Cache
- Cache<K, V>
- ICache<K, V>
- LRUCache
- LRUCache<K, V>
- SynchronizedCache
- SynchronizedCache<K, V>
Org.Apache.Kafka.Common.Config
- AbstractConfig
- Config
- ConfigChangeCallback
- ConfigChangeCallbackDirect
- ConfigData
- ConfigDef
- ConfigDef.CaseInsensitiveValidString
- ConfigDef.CompositeValidator
- ConfigDef.ConfigKey
- ConfigDef.Importance
- ConfigDef.LambdaValidator
- ConfigDef.ListSize
- ConfigDef.NonEmptyString
- ConfigDef.NonEmptyStringWithoutControlChars
- ConfigDef.NonNullValidator
- ConfigDef.Range
- ConfigDef.Recommender
- ConfigDef.Type
- ConfigDef.ValidList
- ConfigDef.ValidString
- ConfigDef.Validator
- ConfigDef.Width
- ConfigException
- ConfigResource
- ConfigResource.Type
- ConfigTransformer
- ConfigTransformerResult
- ConfigValue
- IConfigChangeCallback
- LogLevelConfig
- SaslConfigs
- SecurityConfig
- SslClientAuth
- SslConfigs
- TopicConfig
Org.Apache.Kafka.Common.Config.Provider
- ConfigProvider
- DirectoryConfigProvider
- EnvVarConfigProvider
- FileConfigProvider
- IConfigProvider
Org.Apache.Kafka.Common.Config.Types
- Password
Org.Apache.Kafka.Common.Errors
- ApiException
- AuthenticationException
- AuthorizationException
- AuthorizerNotReadyException
- BrokerIdNotRegisteredException
- BrokerNotAvailableException
- ClusterAuthorizationException
- ConcurrentTransactionsException
- ControllerMovedException
- CoordinatorLoadInProgressException
- CoordinatorNotAvailableException
- CorruptRecordException
- DelegationTokenAuthorizationException
- DelegationTokenDisabledException
- DelegationTokenExpiredException
- DelegationTokenNotFoundException
- DelegationTokenOwnerMismatchException
- DisconnectException
- DuplicateBrokerRegistrationException
- DuplicateResourceException
- DuplicateSequenceException
- DuplicateVoterException
- ElectionNotNeededException
- EligibleLeadersNotAvailableException
- FeatureUpdateFailedException
- FencedInstanceIdException
- FencedLeaderEpochException
- FencedMemberEpochException
- FencedStateEpochException
- FetchSessionIdNotFoundException
- FetchSessionTopicIdException
- GroupAuthorizationException
- GroupIdNotFoundException
- GroupMaxSizeReachedException
- GroupNotEmptyException
- GroupSubscribedToTopicException
- IllegalGenerationException
- IllegalSaslStateException
- InconsistentClusterIdException
- InconsistentGroupProtocolException
- InconsistentTopicIdException
- InconsistentVoterSetException
- IneligibleReplicaException
- InterruptException
- InvalidCommitOffsetSizeException
- InvalidConfigurationException
- InvalidFetchSessionEpochException
- InvalidFetchSizeException
- InvalidGroupIdException
- InvalidMetadataException
- InvalidOffsetException
- InvalidPartitionsException
- InvalidPidMappingException
- InvalidPrincipalTypeException
- InvalidProducerEpochException
- InvalidRecordStateException
- InvalidRegistrationException
- InvalidRegularExpression
- InvalidReplicaAssignmentException
- InvalidReplicationFactorException
- InvalidRequestException
- InvalidRequiredAcksException
- InvalidSessionTimeoutException
- InvalidShareSessionEpochException
- InvalidTimestampException
- InvalidTopicException
- InvalidTxnStateException
- InvalidTxnTimeoutException
- InvalidUpdateVersionException
- InvalidVoterKeyException
- KafkaStorageException
- LeaderNotAvailableException
- ListenerNotFoundException
- LogDirNotFoundException
- MemberIdRequiredException
- MismatchedEndpointTypeException
- NetworkException
- NewLeaderElectedException
- NoReassignmentInProgressException
- NotControllerException
- NotCoordinatorException
- NotEnoughReplicasAfterAppendException
- NotEnoughReplicasException
- NotLeaderForPartitionException
- NotLeaderOrFollowerException
- OffsetMetadataTooLarge
- OffsetMovedToTieredStorageException
- OffsetNotAvailableException
- OffsetOutOfRangeException
- OperationNotAttemptedException
- OutOfOrderSequenceException
- PolicyViolationException
- PositionOutOfRangeException
- PreferredLeaderNotAvailableException
- PrincipalDeserializationException
- ProducerFencedException
- ReassignmentInProgressException
- RebalanceInProgressException
- RebootstrapRequiredException
- RecordBatchTooLargeException
- RecordDeserializationException
- RecordDeserializationException.DeserializationExceptionOrigin
- RecordTooLargeException
- ReplicaNotAvailableException
- ResourceNotFoundException
- RetriableException
- SaslAuthenticationException
- SecurityDisabledException
- SerializationException
- ShareSessionNotFoundException
- SnapshotNotFoundException
- SslAuthenticationException
- StaleBrokerEpochException
- StaleMemberEpochException
- TelemetryTooLargeException
- ThrottlingQuotaExceededException
- TimeoutException
- TopicAuthorizationException
- TopicDeletionDisabledException
- TopicExistsException
- TransactionAbortableException
- TransactionAbortedException
- TransactionCoordinatorFencedException
- TransactionalIdAuthorizationException
- TransactionalIdNotFoundException
- UnacceptableCredentialException
- UnknownControllerIdException
- UnknownLeaderEpochException
- UnknownMemberIdException
- UnknownProducerIdException
- UnknownServerException
- UnknownSubscriptionIdException
- UnknownTopicIdException
- UnknownTopicOrPartitionException
- UnreleasedInstanceIdException
- UnstableOffsetCommitException
- UnsupportedAssignorException
- UnsupportedByAuthenticationException
- UnsupportedCompressionTypeException
- UnsupportedEndpointTypeException
- UnsupportedForMessageFormatException
- UnsupportedSaslMechanismException
- UnsupportedVersionException
- VoterNotFoundException
- WakeupException
Org.Apache.Kafka.Common.Header
- Header
- Headers
- IHeader
- IHeaders
Org.Apache.Kafka.Common.Memory
- GarbageCollectedMemoryPool
- IMemoryPool
- MemoryPool
- SimpleMemoryPool
Org.Apache.Kafka.Common.Metrics
- CompoundStat
- CompoundStat.NamedMeasurable
- Gauge
- Gauge<T>
- ICompoundStat
- IGauge<T>
- IMeasurable
- IMeasurableStat
- IMetricValueProvider<T>
- IMetricsContext
- IMetricsReporter
- IStat
- JmxReporter
- KafkaMetric
- KafkaMetricsContext
- Measurable
- MeasurableStat
- MetricConfig
- MetricValueProvider
- MetricValueProvider<T>
- Metrics
- MetricsContext
- MetricsReporter
- MetricsReporterDirect
- Quota
- QuotaViolationException
- Sensor
- Sensor.RecordingLevel
- Stat
Org.Apache.Kafka.Common.Metrics.Stats
- Avg
- CumulativeCount
- CumulativeSum
- Frequencies
- Frequency
- Histogram
- Histogram.BinScheme
- Histogram.ConstantBinScheme
- Histogram.LinearBinScheme
- Max
- Meter
- Min
- Percentile
- Percentiles
- Percentiles.BucketSizing
- Rate
- SampledStat
- SimpleRate
- TokenBucket
- Value
- WindowedCount
- WindowedSum
Org.Apache.Kafka.Common.Quota
- ClientQuotaAlteration
- ClientQuotaAlteration.Op
- ClientQuotaEntity
- ClientQuotaFilter
- ClientQuotaFilterComponent
Org.Apache.Kafka.Common.Record
- AbstractLegacyRecordBatch
- CompressionType
- ControlRecordType
- ControlRecordUtils
- DefaultRecordBatch
- FileLogInputStream
- FileLogInputStream.FileChannelRecordBatch
- IMutableRecordBatch
- IRecord
- IRecordBatch
- ITransferableRecords
- IUnalignedRecords
- LegacyRecord
- MemoryRecordsBuilder
- MemoryRecordsBuilder.RecordsInfo
- MultiRecordsSend
- MutableRecordBatch
- Record
- RecordBatch
- RecordValidationStats
- RecordVersion
- RecordsUtil
- RemoteLogInputStream
- SimpleRecord
- TimestampType
- TransferableRecords
- UnalignedFileRecords
- UnalignedMemoryRecords
- UnalignedRecords
Org.Apache.Kafka.Common.Replica
- ClientMetadata
- ClientMetadata.DefaultClientMetadata
- IClientMetadata
- IPartitionView
- IReplicaSelector
- IReplicaView
- PartitionView
- PartitionView.DefaultPartitionView
- RackAwareReplicaSelector
- ReplicaSelector
- ReplicaView
- ReplicaView.DefaultReplicaView
Org.Apache.Kafka.Common.Resource
- PatternType
- Resource
- ResourcePattern
- ResourcePatternFilter
- ResourceType
Org.Apache.Kafka.Common.Security
- JaasContext
- JaasContext.Type
- JaasUtils
Org.Apache.Kafka.Common.Security.Auth
- AuthenticateCallbackHandler
- AuthenticationContext
- IAuthenticateCallbackHandler
- IAuthenticationContext
- IKafkaPrincipalBuilder
- IKafkaPrincipalSerde
- ILogin
- ISecurityProviderCreator
- ISslEngineFactory
- KafkaPrincipal
- KafkaPrincipalBuilder
- KafkaPrincipalSerde
- Login
- PlaintextAuthenticationContext
- SaslAuthenticationContext
- SaslExtensions
- SaslExtensionsCallback
- SecurityProtocol
- SecurityProviderCreator
- SslAuthenticationContext
- SslEngineFactory
Org.Apache.Kafka.Common.Security.Authenticator
- AbstractLogin
- AbstractLogin.DefaultLoginCallbackHandler
- CredentialCache
- CredentialCache.Cache
- CredentialCache.Cache<C>
- DefaultKafkaPrincipalBuilder
- DefaultLogin
- LoginManager
- SaslClientAuthenticator
- SaslClientAuthenticator.SaslState
- SaslClientCallbackHandler
- SaslInternalConfigs
- SaslServerAuthenticator
- SaslServerCallbackHandler
Org.Apache.Kafka.Common.Security.Oauthbearer
- IOAuthBearerToken
- OAuthBearerExtensionsValidatorCallback
- OAuthBearerLoginCallbackHandler
- OAuthBearerLoginModule
- OAuthBearerToken
- OAuthBearerTokenCallback
- OAuthBearerValidatorCallback
- OAuthBearerValidatorCallbackHandler
Org.Apache.Kafka.Common.Security.Plain
- PlainAuthenticateCallback
- PlainLoginModule
Org.Apache.Kafka.Common.Security.Plain.Internals
- PlainSaslServer
- PlainSaslServer.PlainSaslServerFactory
- PlainSaslServerProvider
- PlainServerCallbackHandler
Org.Apache.Kafka.Common.Security.Scram
- ScramCredential
- ScramCredentialCallback
- ScramExtensionsCallback
- ScramLoginModule
Org.Apache.Kafka.Common.Security.Ssl
- CommonNameLoggingSslEngineFactory
- DefaultSslEngineFactory
- SslFactory
- SslPrincipalMapper
- SslPrincipalMapper.NoMatchingRule
Org.Apache.Kafka.Common.Security.Token.Delegation
- DelegationToken
- TokenInformation
Org.Apache.Kafka.Common.Serialization
- BooleanDeserializer
- BooleanSerializer
- ByteArrayDeserializer
- ByteArraySerializer
- ByteBufferDeserializer
- ByteBufferSerializer
- BytesDeserializer
- BytesSerializer
- Deserializer
- DeserializerDirect
- DeserializerDirect<T>
- Deserializer<T>
- DoubleDeserializer
- DoubleSerializer
- FloatDeserializer
- FloatSerializer
- IDeserializer
- IDeserializer<T>
- ISerde<T>
- ISerializer
- ISerializer<T>
- IntegerDeserializer
- IntegerSerializer
- ListDeserializer
- ListDeserializer<Inner>
- ListSerializer
- ListSerializer<Inner>
- LongDeserializer
- LongSerializer
- Serde
- SerdeDirect
- SerdeDirect<T>
- Serde<T>
- Serdes
- Serdes.BooleanSerde
- Serdes.ByteArraySerde
- Serdes.ByteBufferSerde
- Serdes.BytesSerde
- Serdes.DoubleSerde
- Serdes.FloatSerde
- Serdes.IntegerSerde
- Serdes.ListSerde
- Serdes.ListSerde<Inner>
- Serdes.LongSerde
- Serdes.ShortSerde
- Serdes.StringSerde
- Serdes.UUIDSerde
- Serdes.VoidSerde
- Serdes.WrapperSerde
- Serdes.WrapperSerde<T>
- Serializer
- SerializerDirect
- SerializerDirect<T>
- Serializer<T>
- ShortDeserializer
- ShortSerializer
- StringDeserializer
- StringSerializer
- UUIDDeserializer
- UUIDSerializer
- VoidDeserializer
- VoidSerializer
Org.Apache.Kafka.Common.Telemetry
- ClientTelemetryState
Org.Apache.Kafka.Common.Utils
- AbstractIterator
- AbstractIterator<T>
- AppInfoParser
- AppInfoParser.AppInfo
- AppInfoParser.AppInfoMBean
- BufferSupplier
- BufferSupplier.GrowableBufferSupplier
- ByteBufferInputStream
- ByteBufferOutputStream
- ByteBufferUnmapper
- ByteUtils
- Bytes
- Checksums
- ChildFirstClassLoader
- ChunkedBytesStream
- CircularIterator
- CircularIterator<T>
- CloseableIterator
- CloseableIterator<T>
- CollectionUtils
- ConfigUtils
- CopyOnWriteMap
- CopyOnWriteMap<K, V>
- Crc32C
- Exit
- Exit.Procedure
- Exit.ShutdownHookAdder
- ExponentialBackoff
- FixedOrderMap
- FixedOrderMap<K, V>
- FlattenedIterator
- FlattenedIterator<O, I>
- ICloseableIterator<T>
- IScheduler
- ITime
- KafkaThread
- LogContext
- LoggingSignalHandler
- MappedIterator
- MappedIterator<F, T>
- OperatingSystem
- PrimitiveRef
- PrimitiveRef.IntRef
- PrimitiveRef.LongRef
- ProducerIdAndEpoch
- PureJavaCrc32C
- Sanitizer
- Scheduler
- SecurityUtils
- Shell
- Shell.ExitCodeException
- Shell.ShellCommandExecutor
- SystemScheduler
- ThreadUtils
- Time
- Timer
- Utils
- Utils.SwallowAction
- Utils.ThrowingRunnable
- Utils.UncheckedCloseable
Org.Apache.Kafka.Connect.Cli
- ConnectDistributed
- ConnectStandalone
Org.Apache.Kafka.Connect.Components
- IVersioned
- Versioned
Org.Apache.Kafka.Connect.Connector
- ConnectRecord
- ConnectRecord<R>
- ConnectRecord<R, TKey, TValue>
- Connector
- ConnectorContext
- IConnectorContext
- ITask
- Task
Org.Apache.Kafka.Connect.Converters
- BooleanConverter
- BooleanConverterConfig
- ByteArrayConverter
- DoubleConverter
- FloatConverter
- IntegerConverter
- LongConverter
- NumberConverterConfig
- ShortConverter
Org.Apache.Kafka.Connect.Data
- ConnectSchema
- Date
- Decimal
- Field
- ISchema
- Schema
- Schema.Type
- SchemaAndValue
- SchemaBuilder
- SchemaProjector
- Struct
- Time
- Timestamp
- Values
Org.Apache.Kafka.Connect.Errors
- AlreadyExistsException
- ConnectException
- DataException
- IllegalWorkerStateException
- NotFoundException
- RetriableException
- SchemaBuilderException
- SchemaProjectorException
Org.Apache.Kafka.Connect.Header
- ConnectHeaders
- Header
- Headers
- Headers.HeaderTransform
- IHeader
- IHeaders
Org.Apache.Kafka.Connect.Health
- AbstractState
- ConnectClusterDetails
- ConnectClusterState
- ConnectorHealth
- ConnectorState
- ConnectorType
- IConnectClusterDetails
- IConnectClusterState
- TaskState
Org.Apache.Kafka.Connect.Json
- DecimalFormat
- JsonConverter
- JsonConverterConfig
- JsonDeserializer
- JsonSchema
- JsonSerializer
Org.Apache.Kafka.Connect.Mirror
- Checkpoint
- CheckpointStore
- ConfigPropertyFilter
- DefaultConfigPropertyFilter
- DefaultGroupFilter
- DefaultReplicationPolicy
- DefaultTopicFilter
- GroupFilter
- Heartbeat
- IConfigPropertyFilter
- IGroupFilter
- IReplicationPolicy
- ITopicFilter
- IdentityReplicationPolicy
- MirrorCheckpointConfig
- MirrorCheckpointConnector
- MirrorCheckpointTask
- MirrorCheckpointTaskConfig
- MirrorClient
- MirrorClientConfig
- MirrorConnectorConfig
- MirrorHeartbeatConfig
- MirrorHeartbeatConnector
- MirrorHeartbeatTask
- MirrorHerder
- MirrorMaker
- MirrorMaker2
- MirrorMakerConfig
- MirrorSourceConfig
- MirrorSourceConnector
- MirrorSourceTask
- MirrorSourceTaskConfig
- MirrorUtils
- OffsetSync
- OffsetSyncStore
- RemoteClusterUtils
- ReplicationPolicy
- SourceAndTarget
- TopicFilter
Org.Apache.Kafka.Connect.Mirror.Formatters
- CheckpointFormatter
- HeartbeatFormatter
- OffsetSyncFormatter
Org.Apache.Kafka.Connect.Rest.Basic.Auth.Extension
- BasicAuthSecurityRestExtension
- PropertyFileLoginModule
Org.Apache.Kafka.Connect.Sink
- ErrantRecordReporter
- IErrantRecordReporter
- ISinkConnectorContext
- ISinkTaskContext
- SinkConnector
- SinkConnectorContext
- SinkRecord
- SinkRecord<TKey, TValue>
- SinkTask
- SinkTaskContext
Org.Apache.Kafka.Connect.Source
- ConnectorTransactionBoundaries
- ExactlyOnceSupport
- ISourceConnectorContext
- ISourceTaskContext
- ITransactionContext
- SourceConnector
- SourceConnectorContext
- SourceRecord
- SourceRecord<TKey, TValue>
- SourceRecord<TKeySource, TOffset, TKey, TValue>
- SourceTask
- SourceTask.TransactionBoundary
- SourceTaskContext
- TransactionContext
Org.Apache.Kafka.Connect.Transforms
- Cast
- Cast.Key
- Cast.Key<R>
- Cast.Value
- Cast.Value<R>
- Cast<R>
- DropHeaders
- DropHeaders<R>
- ExtractField
- ExtractField.Key
- ExtractField.Key<R>
- ExtractField.Value
- ExtractField.Value<R>
- ExtractField<R>
- Filter
- Filter<R>
- Flatten
- Flatten.Key
- Flatten.Key<R>
- Flatten.Value
- Flatten.Value<R>
- Flatten<R>
- HeaderFrom
- HeaderFrom.Key
- HeaderFrom.Key<R>
- HeaderFrom.Value
- HeaderFrom.Value<R>
- HeaderFrom<R>
- HoistField
- HoistField.Key
- HoistField.Key<R>
- HoistField.Value
- HoistField.Value<R>
- HoistField<R>
- ITransformation<R>
- InsertField
- InsertField.Key
- InsertField.Key<R>
- InsertField.Value
- InsertField.Value<R>
- InsertField<R>
- InsertHeader
- InsertHeader<R>
- MaskField
- MaskField.Key
- MaskField.Key<R>
- MaskField.Value
- MaskField.Value<R>
- MaskField<R>
- RegexRouter
- RegexRouter<R>
- ReplaceField
- ReplaceField.Key
- ReplaceField.Key<R>
- ReplaceField.Value
- ReplaceField.Value<R>
- ReplaceField<R>
- SetSchemaMetadata
- SetSchemaMetadata.Key
- SetSchemaMetadata.Key<R>
- SetSchemaMetadata.Value
- SetSchemaMetadata.Value<R>
- SetSchemaMetadata<R>
- TimestampConverter
- TimestampConverter.Key
- TimestampConverter.Key<R>
- TimestampConverter.Value
- TimestampConverter.Value<R>
- TimestampConverter<R>
- TimestampRouter
- TimestampRouter<R>
- Transformation
- Transformation<R>
- ValueToKey
- ValueToKey<R>
Org.Apache.Kafka.Connect.Transforms.Field
- FieldSyntaxVersion
- SingleFieldPath
Org.Apache.Kafka.Connect.Transforms.Predicates
- HasHeaderKey
- HasHeaderKey<R>
- IPredicate<R>
- Predicate
- Predicate<R>
- RecordIsTombstone
- RecordIsTombstone<R>
- TopicNameMatches
- TopicNameMatches<R>
Org.Apache.Kafka.Connect.Transforms.Util
- NonEmptyListValidator
- RegexValidator
- Requirements
- SchemaUtil
- SimpleConfig
Org.Apache.Kafka.Connect.Util
- Callback
- Callback<V>
- ConcreteSubClassValidator
- ConnectUtils
- ConnectorTaskId
- ConnectorUtils
- ConvertingFutureCallback
- ConvertingFutureCallback<U, T>
- FutureCallback
- FutureCallback<T>
- ICallback<V>
- InstantiableClassValidator
- KafkaBasedLog
- KafkaBasedLog<K, V>
- LoggingContext
- LoggingContext.Scope
- RetryUtil
- SafeObjectInputStream
- SinkUtils
- Stage
- StagedTimeoutException
- Table
- Table<R, C, V>
- TemporaryStage
- TopicAdmin
- TopicAdmin.NewTopicBuilder
- TopicAdmin.TopicCreationResponse
- TopicCreation
- TopicCreationGroup
Org.Apache.Kafka.Deferred
- DeferredEvent
- DeferredEventQueue
- IDeferredEvent
Org.Apache.Kafka.Metadata
- AssignmentsHelper
Org.Apache.Kafka.Queue
- EventQueue
- EventQueue.DeadlineFunction
- EventQueue.EarliestDeadlineFunction
- EventQueue.Event
- EventQueue.EventInsertionType
- EventQueue.FailureLoggingEvent
- EventQueue.LatestDeadlineFunction
- EventQueue.NoDeadlineFunction
- EventQueue.VoidEvent
- IEventQueue
- KafkaEventQueue
Org.Apache.Kafka.Raft
- Batch
- BatchReader
- BatchReader<T>
- Batch<T>
- CandidateState
- ControlRecord
- DynamicVoter
- DynamicVoters
- ElectionState
- Endpoints
- EpochState
- ExpirationService
- ExternalKRaftMetrics
- FileQuorumStateStore
- FollowerState
- IBatchReader<T>
- IEpochState
- IExpirationService
- IExternalKRaftMetrics
- INetworkChannel
- IOffsetMetadata
- IQuorumStateStore
- IRaftClient<T>
- IRaftMessage
- IRaftMessageQueue
- IReplicatedLog
- Isolation
- KafkaNetworkChannel
- KafkaRaftClient
- KafkaRaftClientDriver
- KafkaRaftClientDriver<T>
- KafkaRaftClient<T>
- LeaderAndEpoch
- LeaderState
- LeaderState.ReplicaState
- LeaderState<T>
- LogAppendInfo
- LogFetchInfo
- LogOffsetMetadata
- NetworkChannel
- OffsetAndEpoch
- OffsetMetadata
- ProspectiveState
- QuorumConfig
- QuorumConfig.ControllerQuorumBootstrapServersValidator
- QuorumConfig.ControllerQuorumVotersValidator
- QuorumState
- QuorumStateStore
- RaftClient
- RaftClient.Listener
- RaftClient.ListenerDirect
- RaftClient.ListenerDirect<T>
- RaftClient.Listener<T>
- RaftClient<T>
- RaftMessage
- RaftMessageQueue
- RaftRequest
- RaftRequest.Inbound
- RaftRequest.Outbound
- RaftResponse
- RaftResponse.Inbound
- RaftResponse.Outbound
- RaftUtil
- ReplicaKey
- ReplicatedLog
- RequestManager
- ResignedState
- UnattachedState
- ValidOffsetAndEpoch
- ValidOffsetAndEpoch.Kind
- VoterSet
- VoterSet.VoterNode
Org.Apache.Kafka.Raft.Errors
- BufferAllocationException
- NotLeaderException
- RaftException
Org.Apache.Kafka.Raft.Generated
- QuorumStateData
- QuorumStateData.Voter
- QuorumStateDataJsonConverter
- QuorumStateDataJsonConverter.VoterJsonConverter
Org.Apache.Kafka.Security
- IPasswordEncoder
- PasswordEncoder
Org.Apache.Kafka.Shell
- InteractiveShell
- InteractiveShell.HistoryIterator
- MetadataShell
- MetadataShell.Builder
Org.Apache.Kafka.Snapshot
- FileRawSnapshotReader
- FileRawSnapshotWriter
- IRawSnapshotReader
- IRawSnapshotWriter
- ISnapshotReader<T>
- ISnapshotWriter<T>
- NotifyingRawSnapshotWriter
- RawSnapshotReader
- RawSnapshotWriter
- RecordsSnapshotReader
- RecordsSnapshotReader<T>
- RecordsSnapshotWriter
- RecordsSnapshotWriter.Builder
- RecordsSnapshotWriter<T>
- SnapshotPath
- SnapshotReader
- SnapshotReader<T>
- SnapshotWriter
- SnapshotWriter<T>
- Snapshots
Org.Apache.Kafka.Streams
- AutoOffsetReset
- ClientInstanceIds
- IClientInstanceIds
- IKafkaClientSupplier
- IStreamsMetadata
- IStreamsMetrics
- ITaskMetadata
- IThreadMetadata
- ITopologyDescription
- KafkaClientSupplier
- KafkaClientSupplierDirect
- KafkaStreams
- KafkaStreams.CloseOptions
- KafkaStreams.IStateListener
- KafkaStreams.State
- KafkaStreams.StateListener
- KafkaStreams.StateListenerDirect
- KeyQueryMetadata
- KeyValue
- KeyValue<K, V>
- LagInfo
- StoreQueryParameters
- StoreQueryParameters<T>
- StreamsBuilder
- StreamsConfig
- StreamsConfig.InternalConfig
- StreamsMetadata
- StreamsMetrics
- TaskMetadata
- ThreadMetadata
- Topology
- TopologyConfig
- TopologyConfig.TaskConfig
- TopologyDescription
- TopologyDescription.GlobalStore
- TopologyDescription.Node
- TopologyDescription.Processor
- TopologyDescription.Sink
- TopologyDescription.Source
- TopologyDescription.Subtopology
Org.Apache.Kafka.Streams.Errors
- BrokerNotFoundException
- DefaultProductionExceptionHandler
- DeserializationExceptionHandler
- DeserializationExceptionHandler.DeserializationHandlerResponse
- ErrorHandlerContext
- IDeserializationExceptionHandler
- IErrorHandlerContext
- IProcessingExceptionHandler
- IProductionExceptionHandler
- IStreamsUncaughtExceptionHandler
- InvalidStateStoreException
- InvalidStateStorePartitionException
- LockException
- LogAndContinueExceptionHandler
- LogAndContinueProcessingExceptionHandler
- LogAndFailExceptionHandler
- LogAndFailProcessingExceptionHandler
- MissingSourceTopicException
- ProcessingExceptionHandler
- ProcessingExceptionHandler.ProcessingHandlerResponse
- ProcessorStateException
- ProductionExceptionHandler
- ProductionExceptionHandler.ProductionExceptionHandlerResponse
- ProductionExceptionHandler.SerializationExceptionOrigin
- StateStoreMigratedException
- StateStoreNotAvailableException
- StreamsException
- StreamsNotStartedException
- StreamsRebalancingException
- StreamsStoppedException
- StreamsUncaughtExceptionHandler
- StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse
- StreamsUncaughtExceptionHandlerDirect
- TaskAssignmentException
- TaskCorruptedException
- TaskIdFormatException
- TaskMigratedException
- TopologyException
- UnknownStateStoreException
- UnknownTopologyException
Org.Apache.Kafka.Streams.Errors.Internals
- DefaultErrorHandlerContext
- FailedProcessingException
Org.Apache.Kafka.Streams.Kstream
- Aggregator
- AggregatorDirect
- AggregatorDirect<K, V, VAgg>
- Aggregator<K, V, VAgg>
- Branched
- BranchedKStream
- BranchedKStream<K, V>
- Branched<K, V>
- CogroupedKStream
- CogroupedKStream<K, VAgg>
- Consumed
- Consumed<K, V>
- EmitStrategy
- EmitStrategy.StrategyType
- ForeachAction
- ForeachActionDirect
- ForeachActionDirect<K, V>
- ForeachAction<K, V>
- GlobalKTable
- GlobalKTable<K, V>
- Grouped
- Grouped<K, V>
- IAggregator<K, V, VAgg>
- IBranchedKStream<K, V>
- ICogroupedKStream<K, VAgg>
- IEmitStrategy
- IForeachAction<K, V>
- IGlobalKTable<K, V>
- IInitializer<VAgg>
- IKGroupedStream<K, V>
- IKGroupedTable<K, V>
- IKStream<K, V>
- IKTable<K, V>
- IKeyValueMapper<K, V, VR>
- IMerger<K, V>
- INamedOperation<T>
- IPredicate<K, V>
- IReducer<V>
- ISessionWindowedCogroupedKStream<K, V>
- ISessionWindowedKStream<K, V>
- ISuppressed<K>
- ITimeWindowedCogroupedKStream<K, V>
- ITimeWindowedKStream<K, V>
- IValueJoinerWithKey<K1, V1, V2, VR>
- IValueJoiner<V1, V2, VR>
- IValueMapperWithKey<K, V, VR>
- IValueMapper<V, VR>
- IValueTransformerWithKeySupplier<K, V, VR>
- IValueTransformerWithKey<K, V, VR>
- Initializer
- InitializerDirect
- InitializerDirect<VAgg>
- Initializer<VAgg>
- JoinWindows
- Joined
- Joined<K, VLeft, VRight>
- KGroupedStream
- KGroupedStream<K, V>
- KGroupedTable
- KGroupedTable<K, V>
- KStream
- KStream<K, V>
- KTable
- KTable<K, V>
- KeyValueMapper
- KeyValueMapperDirect
- KeyValueMapperDirect<K, V, VR>
- KeyValueMapper<K, V, VR>
- Materialized
- Materialized.StoreType
- Materialized<K, V, S>
- Merger
- MergerDirect
- MergerDirect<K, V>
- Merger<K, V>
- Named
- NamedOperation
- NamedOperation<T>
- Predicate
- PredicateDirect
- PredicateDirect<K, V>
- Predicate<K, V>
- Printed
- Printed<K, V>
- Produced
- Produced<K, V>
- Reducer
- ReducerDirect
- ReducerDirect<V>
- Reducer<V>
- Repartitioned
- Repartitioned<K, V>
- SessionWindowedCogroupedKStream
- SessionWindowedCogroupedKStream<K, V>
- SessionWindowedDeserializer
- SessionWindowedDeserializer<T>
- SessionWindowedKStream
- SessionWindowedKStream<K, V>
- SessionWindowedSerializer
- SessionWindowedSerializer<T>
- SessionWindows
- SlidingWindows
- StreamJoined
- StreamJoined<K, V1, V2>
- Suppressed
- Suppressed.BufferConfig
- Suppressed.BufferConfig<BC>
- Suppressed.EagerBufferConfig
- Suppressed.StrictBufferConfig
- Suppressed<K>
- TableJoined
- TableJoined<K, KO>
- TimeWindowedCogroupedKStream
- TimeWindowedCogroupedKStream<K, V>
- TimeWindowedDeserializer
- TimeWindowedDeserializer<T>
- TimeWindowedKStream
- TimeWindowedKStream<K, V>
- TimeWindowedSerializer
- TimeWindowedSerializer<T>
- TimeWindows
- UnlimitedWindows
- ValueJoiner
- ValueJoinerDirect
- ValueJoinerDirect<V1, V2, VR>
- ValueJoinerWithKey
- ValueJoinerWithKeyDirect
- ValueJoinerWithKeyDirect<K1, V1, V2, VR>
- ValueJoinerWithKey<K1, V1, V2, VR>
- ValueJoiner<V1, V2, VR>
- ValueMapper
- ValueMapperDirect
- ValueMapperDirect<V, VR>
- ValueMapperWithKey
- ValueMapperWithKeyDirect
- ValueMapperWithKeyDirect<K, V, VR>
- ValueMapperWithKey<K, V, VR>
- ValueMapper<V, VR>
- ValueTransformerWithKey
- ValueTransformerWithKeyDirect
- ValueTransformerWithKeyDirect<K, V, VR>
- ValueTransformerWithKeySupplier<K, V, VR>
- ValueTransformerWithKey<K, V, VR>
- Window
- Windowed
- WindowedSerdes
- WindowedSerdes.SessionWindowedSerde
- WindowedSerdes.SessionWindowedSerde<T>
- WindowedSerdes.TimeWindowedSerde
- WindowedSerdes.TimeWindowedSerde<T>
- Windowed<K>
- Windows
- Windows<W>
Org.Apache.Kafka.Streams.Kstream.Internals
- TimeWindow
- UnlimitedWindow
Org.Apache.Kafka.Streams.Processor
- BatchingStateRestoreCallback
- BatchingStateRestoreCallbackDirect
- Cancellable
- CommitCallback
- ConnectedStoreProvider
- FailOnInvalidTimestamp
- IBatchingStateRestoreCallback
- ICancellable
- ICommitCallback
- IConnectedStoreProvider
- IProcessorContext
- IPunctuator
- IRecordContext
- IStandbyUpdateListener
- IStateRestoreCallback
- IStateRestoreListener
- IStateStore
- IStateStoreContext
- IStreamPartitioner<K, V>
- ITimestampExtractor
- ITopicNameExtractor
- ITopicNameExtractor<K, V>
- LogAndSkipOnInvalidTimestamp
- ProcessorContext
- PunctuationType
- Punctuator
- PunctuatorDirect
- RecordContext
- StandbyUpdateListener
- StandbyUpdateListener.SuspendReason
- StandbyUpdateListenerDirect
- StateRestoreCallback
- StateRestoreCallbackDirect
- StateRestoreListener
- StateRestoreListenerDirect
- StateStore
- StateStoreContext
- StreamPartitioner
- StreamPartitionerDirect
- StreamPartitionerDirect<K, V>
- StreamPartitioner<K, V>
- TaskId
- TimestampExtractor
- TimestampExtractorDirect
- To
- TopicNameExtractor
- TopicNameExtractorDirect
- TopicNameExtractorDirect<K, V>
- TopicNameExtractor<K, V>
- UsePartitionTimeOnInvalidTimestamp
- WallclockTimestampExtractor
Org.Apache.Kafka.Streams.Processor.Api
- ContextualFixedKeyProcessor
- ContextualFixedKeyProcessor<KIn, VIn, VOut>
- ContextualProcessor
- ContextualProcessor<KIn, VIn, KOut, VOut>
- FixedKeyProcessor
- FixedKeyProcessorContext
- FixedKeyProcessorContext<KForward, VForward>
- FixedKeyProcessorDirect
- FixedKeyProcessorDirect<KIn, VIn, VOut>
- FixedKeyProcessorSupplier
- FixedKeyProcessorSupplier<KIn, VIn, VOut>
- FixedKeyProcessor<KIn, VIn, VOut>
- FixedKeyRecord
- FixedKeyRecord<K, V>
- IFixedKeyProcessorContext<KForward, VForward>
- IFixedKeyProcessorSupplier<KIn, VIn, VOut>
- IFixedKeyProcessor<KIn, VIn, VOut>
- IProcessingContext
- IProcessorContext<KForward, VForward>
- IProcessorSupplier<KIn, VIn, KOut, VOut>
- IProcessorWrapper
- IProcessor<KIn, VIn, KOut, VOut>
- IRecordMetadata
- IWrappedFixedKeyProcessorSupplier<KIn, VIn, VOut>
- IWrappedProcessorSupplier<KIn, VIn, KOut, VOut>
- InternalFixedKeyRecordFactory
- ProcessingContext
- Processor
- ProcessorContext
- ProcessorContext<KForward, VForward>
- ProcessorDirect
- ProcessorDirect<KIn, VIn, KOut, VOut>
- ProcessorSupplier
- ProcessorSupplier<KIn, VIn, KOut, VOut>
- ProcessorWrapper
- Processor<KIn, VIn, KOut, VOut>
- Record
- RecordMetadata
- Record<K, V>
- WrappedFixedKeyProcessorSupplier
- WrappedFixedKeyProcessorSupplier<KIn, VIn, VOut>
- WrappedProcessorSupplier
- WrappedProcessorSupplier<KIn, VIn, KOut, VOut>
Org.Apache.Kafka.Streams.Processor.Assignment
- ApplicationState
- AssignmentConfigs
- IApplicationState
- IKafkaStreamsState
- ITaskAssignor
- ITaskInfo
- ITaskTopicPartition
- KafkaStreamsAssignment
- KafkaStreamsState
- ProcessId
- TaskAssignmentUtils
- TaskAssignmentUtils.MoveStandbyTaskPredicate
- TaskAssignmentUtils.RackAwareOptimizationParams
- TaskAssignor
- TaskAssignor.AssignmentError
- TaskAssignor.TaskAssignment
- TaskInfo
- TaskTopicPartition
Org.Apache.Kafka.Streams.Processor.Assignment.Assignors
- StickyTaskAssignor
Org.Apache.Kafka.Streams.Query
- FailureReason
- IQueryResult<R>
- IQuery<R>
- KeyQuery
- KeyQuery<K, V>
- MultiVersionedKeyQuery
- MultiVersionedKeyQuery<K, V>
- Position
- PositionBound
- Query
- QueryConfig
- QueryResult
- QueryResult<R>
- Query<R>
- RangeQuery
- RangeQuery<K, V>
- ResultOrder
- StateQueryRequest
- StateQueryRequest.InStore
- StateQueryRequest<R>
- StateQueryResult
- StateQueryResult<R>
- TimestampedKeyQuery
- TimestampedKeyQuery<K, V>
- TimestampedRangeQuery
- TimestampedRangeQuery<K, V>
- VersionedKeyQuery
- VersionedKeyQuery<K, V>
- WindowKeyQuery
- WindowKeyQuery<K, V>
- WindowRangeQuery
- WindowRangeQuery<K, V>
Org.Apache.Kafka.Streams.Scala
- FunctionsCompatConversions
- FunctionsCompatConversions.AggregatorFromFunction
- FunctionsCompatConversions.AggregatorFromFunction<K, V, VA>
- FunctionsCompatConversions.FlatValueMapperFromFunction
- FunctionsCompatConversions.FlatValueMapperFromFunction<V, VR>
- FunctionsCompatConversions.FlatValueMapperWithKeyFromFunction
- FunctionsCompatConversions.FlatValueMapperWithKeyFromFunction<K, V, VR>
- FunctionsCompatConversions.ForeachActionFromFunction
- FunctionsCompatConversions.ForeachActionFromFunction<K, V>
- FunctionsCompatConversions.FunctionFromFunction
- FunctionsCompatConversions.FunctionFromFunction<V, VR>
- FunctionsCompatConversions.InitializerFromFunction
- FunctionsCompatConversions.InitializerFromFunction<VA>
- FunctionsCompatConversions.KeyValueMapperFromFunction
- FunctionsCompatConversions.KeyValueMapperFromFunction<K, V, KR, VR>
- FunctionsCompatConversions.MapperFromFunction
- FunctionsCompatConversions.MapperFromFunction<T, U, VR>
- FunctionsCompatConversions.MergerFromFunction
- FunctionsCompatConversions.MergerFromFunction<K, VR>
- FunctionsCompatConversions.PredicateFromFunction
- FunctionsCompatConversions.PredicateFromFunction<K, V>
- FunctionsCompatConversions.ReducerFromFunction
- FunctionsCompatConversions.ReducerFromFunction<V>
- FunctionsCompatConversions.TransformerSupplierAsJava
- FunctionsCompatConversions.TransformerSupplierAsJava<K, V, VO>
- FunctionsCompatConversions.TransformerSupplierFromFunction
- FunctionsCompatConversions.TransformerSupplierFromFunction<K, V, VO>
- FunctionsCompatConversions.ValueMapperFromFunction
- FunctionsCompatConversions.ValueMapperFromFunction<V, VR>
- FunctionsCompatConversions.ValueMapperWithKeyFromFunction
- FunctionsCompatConversions.ValueMapperWithKeyFromFunction<K, V, VR>
- FunctionsCompatConversions.ValueTransformerSupplierAsJava
- FunctionsCompatConversions.ValueTransformerSupplierAsJava<V, VO>
- FunctionsCompatConversions.ValueTransformerSupplierWithKeyAsJava
- FunctionsCompatConversions.ValueTransformerSupplierWithKeyAsJava<K, V, VO>
- ImplicitConversions
- StreamsBuilder
- package
Org.Apache.Kafka.Streams.Scala.Kstream
- Branched
- BranchedKStream
- BranchedKStream<K, V>
- CogroupedKStream
- CogroupedKStream<KIn, VOut>
- Consumed
- Grouped
- Joined
- KGroupedStream
- KGroupedStream<K, V>
- KGroupedTable
- KGroupedTable<K, V>
- KStream
- KStream<K, V>
- KTable
- KTable<K, V>
- Materialized
- Produced
- Repartitioned
- SessionWindowedCogroupedKStream
- SessionWindowedCogroupedKStream<K, V>
- SessionWindowedKStream
- SessionWindowedKStream<K, V>
- StreamJoined
- TimeWindowedCogroupedKStream
- TimeWindowedCogroupedKStream<K, V>
- TimeWindowedKStream
- TimeWindowedKStream<K, V>
- package
Org.Apache.Kafka.Streams.Scala.Serialization
- ILowPrioritySerdes
- LowPrioritySerdes
- Serdes
Org.Apache.Kafka.Streams.State
- BuiltInDslStoreSuppliers
- BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers
- BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers
- DslKeyValueParams
- DslSessionParams
- DslStoreSuppliers
- DslWindowParams
- HostInfo
- IDslStoreSuppliers
- IKeyValueBytesStoreSupplier
- IKeyValueIterator<K, V>
- IKeyValueStore<K, V>
- IQueryableStoreType<T>
- IReadOnlyKeyValueStore<K, V>
- IReadOnlySessionStore<K, AGG>
- IReadOnlyWindowStore<K, V>
- IRocksDBConfigSetter
- ISessionBytesStoreSupplier
- ISessionStore<K, AGG>
- IStoreBuilder<T>
- IStoreSupplier
- IStoreSupplier<T>
- ITimestampedBytesStore
- ITimestampedKeyValueStore<K, V>
- ITimestampedWindowStore<K, V>
- IVersionedBytesStore
- IVersionedBytesStoreSupplier
- IVersionedKeyValueStore<K, V>
- IVersionedRecordIterator<V>
- IWindowBytesStoreSupplier
- IWindowStoreIterator<V>
- IWindowStore<K, V>
- KeyValueBytesStoreSupplier
- KeyValueIterator
- KeyValueIterator<K, V>
- KeyValueStore
- KeyValueStore<K, V>
- QueryableStoreType
- QueryableStoreType<T>
- QueryableStoreTypes
- QueryableStoreTypes.KeyValueStoreType
- QueryableStoreTypes.KeyValueStoreType<K, V>
- QueryableStoreTypes.SessionStoreType
- QueryableStoreTypes.SessionStoreType<K, V>
- QueryableStoreTypes.WindowStoreType
- QueryableStoreTypes.WindowStoreType<K, V>
- ReadOnlyKeyValueStore
- ReadOnlyKeyValueStore<K, V>
- ReadOnlySessionStore
- ReadOnlySessionStore<K, AGG>
- ReadOnlyWindowStore
- ReadOnlyWindowStore<K, V>
- RocksDBConfigSetter
- SessionBytesStoreSupplier
- SessionStore
- SessionStore<K, AGG>
- StateSerdes
- StateSerdes<K, V>
- StoreBuilder
- StoreBuilder<T>
- StoreSupplier
- StoreSupplier<T>
- Stores
- TimestampedBytesStore
- TimestampedKeyValueStore
- TimestampedKeyValueStore<K, V>
- TimestampedWindowStore
- TimestampedWindowStore<K, V>
- ValueAndTimestamp
- ValueAndTimestamp<V>
- VersionedBytesStore
- VersionedBytesStoreSupplier
- VersionedKeyValueStore
- VersionedKeyValueStore<K, V>
- VersionedRecord
- VersionedRecordIterator
- VersionedRecordIterator<V>
- VersionedRecord<V>
- WindowBytesStoreSupplier
- WindowStore
- WindowStoreIterator
- WindowStoreIterator<V>
- WindowStore<K, V>
Org.Apache.Kafka.Tools
- AclCommand
- AclCommand.AclCommandOptions
- BrokerApiVersionsCommand
- ClientCompatibilityTest
- ClientMetricsCommand
- ClientMetricsCommand.ClientMetricsCommandOptions
- ClientMetricsCommand.ClientMetricsService
- ClusterTool
- ConnectPluginPath
- ConsoleProducer
- ConsumerPerformance
- DelegationTokenCommand
- DeleteRecordsCommand
- EndToEndLatency
- FeatureCommand
- GetOffsetShell
- GroupsCommand
- GroupsCommand.GroupsCommandOptions
- GroupsCommand.GroupsService
- JmxTool
- LeaderElectionCommand
- LineMessageReader
- LogDirsCommand
- ManifestWorkspace
- ManifestWorkspace.SourceWorkspace
- ManifestWorkspace.SourceWorkspace<T>
- MetadataQuorumCommand
- OAuthCompatibilityTool
- ProducerPerformance
- PushHttpMetricsReporter
- ReplicaVerificationTool
- StreamsResetter
- TerseException
- ToolsUtils
- TopicCommand
- TopicCommand.TopicCommandOptions
- TopicCommand.TopicService
- TransactionalMessageCopier
- TransactionsCommand
- VerifiableConsumer
- VerifiableProducer
Org.Apache.Kafka.Tools.Api
- Decoder
- Decoder<T>
- DefaultDecoder
- IDecoder<T>
- IRecordReader
- IntegerDecoder
- LongDecoder
- RecordReader
- StringDecoder
Org.Apache.Kafka.Tools.Consumer
- ApiMessageFormatter
- ConsoleConsumer
- ConsoleConsumer.ConsumerWrapper
- ConsoleConsumerOptions
- ConsoleShareConsumer
- ConsoleShareConsumer.ConsumerWrapper
- ConsoleShareConsumerOptions
- GroupMetadataMessageFormatter
- OffsetsMessageFormatter
- TransactionLogMessageFormatter
Org.Apache.Kafka.Tools.Consumer.Group
- ConsumerGroupCommand
- ConsumerGroupCommandOptions
- CsvUtils
- CsvUtils.CsvRecordNoGroup
- CsvUtils.CsvRecordWithGroup
- ShareGroupCommand
- ShareGroupCommandOptions
Org.Apache.Kafka.Tools.Consumer.Group.Share
- ShareGroupStateMessageFormatter
Org.Apache.Kafka.Tools.Filter
- IPartitionFilter
- ITopicPartitionFilter
- PartitionFilter
- PartitionFilter.PartitionRangeFilter
- PartitionFilter.PartitionsSetFilter
- PartitionFilter.UniquePartitionFilter
- TopicFilter
- TopicFilter.IncludeList
- TopicPartitionFilter
- TopicPartitionFilter.CompositeTopicPartitionFilter
- TopicPartitionFilter.TopicFilterAndPartitionFilter
Org.Apache.Kafka.Tools.Reassign
- ReassignPartitionsCommand
- ReassignPartitionsCommandOptions
- VerifyAssignmentResult