Skip to content
The Internals of Apache Kafka
Callback
Initializing search
kafka-internals
Apache Kafka
Features
Internals
Controller
Broker
Clients
Tools
Misc
Demos
The Internals of Apache Kafka
kafka-internals
Apache Kafka
Features
Features
Consumer Groups
Consumer Groups
GroupCoordinator
GroupMetadataManager
OffsetConfig
Controller Election
Dynamic Broker Configuration
Dynamic Broker Configuration
BrokerConfigHandler
BrokerReconfigurable
ConfigHandler
DynamicBrokerConfig
DynamicLogConfig
DynamicThreadPool
TopicConfigHandler
ZkConfigManager
ZkNodeChangeNotificationListener
Dynamic Configuration
Dynamic Configuration
Reconfigurable
Kafka Raft (KRaft)
Kafka Raft (KRaft)
BrokerServer
ControllerServer
FileBasedStateStore
KafkaMetadataLog
KafkaRaftClient.ListenerContext
KafkaRaftClient
KafkaRaftManager
KafkaRaftServer
MetaProperties
QuorumState
QuorumStateStore
RaftClient.Listener
RaftClient
RaftConfig
RaftIoThread
RaftManager
SharedServer
Log Cleanup
Log Cleanup
Metadata
Metadata
BrokerMetadataPublisher
LoaderManifest
MetadataLoader
MetadataLoaderMetrics
MetadataPublisher
QuorumController
SnapshotGenerator
SnapshotManifest
Metrics
Metrics
KafkaMetricsGroup
MetricConfig
Metrics
MetricsReporter
Sensor
Partition Leader Election
Partition Leader Election
Security
Security
Authentication
Authorization
Authorization
AclApis
AclAuthorizer
AclPublisher
AuthHelper
Authorizer
ClusterMetadataAuthorizer
StandardAuthorizer
Tiered Storage
Tiered Storage
RemoteLogManager
RemoteLogManagerConfig
Transactions
Transactions
TransactionConfig
TransactionCoordinator
TransactionMarkerChannelManager
TransactionStateManager
Internals
Internals
Overview
AbstractConfig
AbstractRequest
ApiRequestHandler
AutoTopicCreationManager
BrokerMetadataCheckpoint
Configurable
DefaultAutoTopicCreationManager
FetchResponseData
InterBrokerSendThread
Kafka
KafkaApis
KafkaConfig
Log
LogManager
LogManager
LogCleaner
LogCleaner
LogCleaner
LogCleanerManager
CleanerConfig
CleanerThread
LogConfig
LocalLog
LogLoader
LogManager
LogSegment
UnifiedLog
Partition
PartitionData
RequestHandlerHelper
ReplicaAlterLogDirsThread
ReplicaManager
Server
TopicConfig
Utils
ZkAdminManager
Zookeeper
Zookeeper
AdminZkClient
KafkaZkClient
TopicPartitionStateZNode
Controller
Controller
AbstractControllerBrokerRequestBatch
ControllerBrokerRequestBatch
ControllerChannelManager
ControllerContext
ControllerEvents
ControllerEvents
ControllerEvent
AutoPreferredReplicaLeaderElection
TopicUncleanLeaderElectionEnable
ControllerEventManager
ControllerEventProcessor
Controller Requests
Controller Requests
AbstractControlRequest
LeaderAndIsrRequest
ControllerState
ControllerEventThread
Election
KafkaController
PartitionLeaderElectionAlgorithms
PartitionStateMachine
QueuedEvent
ReplicaStateMachine
TopicDeletionManager
ZkPartitionStateMachine
ZkReplicaStateMachine
Broker
Broker
KafkaBroker
KafkaServer
RaftControllerNodeProvider
Clients
Clients
Admin
Admin
Admin
AdminClientRunnable
KafkaAdminClient
Consumers
Consumers
AbstractCoordinator
AbstractPartitionAssignor
Consumer
ConsumerConfig
ConsumerCoordinator
ConsumerMetadata
ConsumerNetworkClient
ConsumerPartitionAssignor
Fetcher
KafkaConsumer
Preferred Read Replica
SubscriptionState
TopicPartitionState
CommonClientConfigs
KafkaClient
Metadata
MetadataUpdater
NetworkClient
NetworkClientUtils
Producers
Producers
BufferPool
Callback
DefaultPartitioner
KafkaProducer
Partitioner
Producer
ProducerBatch
ProducerConfig
ProducerInterceptors
RecordAccumulator
Sender
TransactionManager
Serde
Serdes
Tools
Tools
kafka-acls
kafka-acls
AclCommand
AclCommandOptions
AclCommandService
AdminClientService
AuthorizerService
kafka-configs
kafka-configs
ConfigCommand
kafka-cluster
kafka-cluster
kafka-console-consumer
kafka-console-consumer
ConsoleConsumer
kafka-dump-log
kafka-dump-log
kafka-get-offsets
kafka-get-offsets
GetOffsetShell
kafka-leader-election
kafka-leader-election
kafka-metadata-shell
kafka-metadata-shell
MetadataShell
MetadataShellPublisher
kafka-reassign-partitions
kafka-reassign-partitions
Demo
ReassignPartitionsCommand
kafka-replica-verification
kafka-replica-verification
ReplicaBuffer
ReplicaFetcher
ReplicaVerificationTool
kafka-storage
kafka-storage
StorageTool
Misc
Misc
Building from Sources
Logging
MetadataCache
RequestHandlerHelper
Demos
Demos
ACL Authorization
Controller Election
Kafka and kcat in Docker
Secure Inter-Broker Communication
Securing Communication Between Clients and Brokers Using SSL
SSL Authentication
Transactional Kafka Producer
Using kafka-leader-election for Partition Leader Election
Apache Kafka
Clients
Producers
Callback
¶
Callback
is...FIXME
Back to top