The Internals of Apache Kafka
Introduction
Overview of Kafka
Kafka Operations and Administration
ConfigCommand
ReassignPartitionsCommand — Partition Reassignment on Command Line
TopicCommand — Topic Management on Command Line
kafka-consumer-groups.sh
ConsumerGroupCommand
KafkaConsumerGroupService
ConsumerGroupService
KafkaAdminClient
AdminClient
AdminUtils
Kafka Features
Kafka Controller Election
Topic Replication
Topic Deletion
Kafka Broker Services
Kafka Server and Periodic Tasks
AdminManager
Authorizer
DynamicBrokerConfig
DynamicLogConfig
DynamicMetricsReporters
DynamicClientQuotaCallback
ConfigHandler Contract
BrokerConfigHandler
ClientIdConfigHandler
TopicConfigHandler
UserConfigHandler
DelegationTokenManager
DynamicConfigManager
BrokerReconfigurable Contract — Reconfigurable Broker Services
DynamicThreadPool
DynamicListenerConfig
LogCleaner
Fetcher
GroupCoordinator
GroupMetadataManager
InterBrokerSendThread
Kafka
KafkaApis — API Request Handler
KafkaController
KafkaHealthcheck
KafkaServerStartable — Thin Management Layer over KafkaServer
KafkaServer
KafkaConfig
KafkaMetricsReporter
KafkaRequestHandler
KafkaRequestHandlerPool — Pool of Daemon KafkaRequestHandler Threads
Log
LogCleanerManager
LogManager
ProducerStateManager
Metadata
Metadata Update Listener
MetadataCache
MetadataUpdater
DefaultMetadataUpdater
OffsetConfig
ReplicaManager
ReplicaFetcherManager
AbstractFetcherManager
ReplicaFetcherThread
AbstractFetcherThread
ReplicaFetcherBlockingSend
ReplicationQuotaManager
ReplicationUtils
LogDirFailureHandler
Selector — Selectable on Socket Channels (from Java’s New IO API)
Selectable
ShutdownableThread
SocketServer
TransactionCoordinator
TransactionStateManager
ZkUtils
ZKRebalancerListener
Kafka Controller
ControllerContext
ControllerEventManager
ControllerEventThread
ControllerEvent
AutoPreferredReplicaLeaderElection
Startup
Reelect
TopicDeletion
ControllerState
ControllerChannelManager
ControllerBrokerRequestBatch
TopicDeletionManager
ReplicaStateMachine
PartitionStateMachine
Kafka Cluster
Partition
Replica
Kafka Metrics
BrokerTopicStats
BrokerTopicMetrics
KafkaMetricsGroup
Kafka Producer API
Producer
KafkaProducer
Sender
ProducerRecord
Callback
ProducerConfig
Partitioner
DefaultPartitioner
ProducerInterceptor
Serializer
Kafka Consumer API
KafkaConsumer — Main Class For Kafka Consumers
Consumer
Deserializer
ConsumerConfig
ConsumerCoordinator
AbstractCoordinator
ConsumerInterceptor
ConsumerNetworkClient
ConsumerRebalanceListener
SubscriptionState
Kafka Architecture
Broker Nodes — Kafka Servers
Broker
Topics
Messages
Kafka Clients
Producers
Consumers
RequestCompletionHandler
ClientResponse
ClientRequest
Clusters
Kafka Monitoring (Metrics)
Metrics
Sensor
MetricsReporter
ProducerMetrics
SenderMetrics
Kafka Tools
Kafka Tools
kafka-configs.sh
kafka-topics.sh
Kafka Configuration
Properties
bootstrap.servers
client.id
enable.auto.commit
group.id
retry.backoff.ms
Logging
Tips and Tricks
Gradle Tips
Zookeeper Tips
Kafka in Scala REPL for Interactive Exploration
Running Kafka Broker in Docker
Kafka Clients
KafkaClient
NetworkClient — Non-Blocking KafkaClient
NetworkClientUtils
Configurable Contract
Reconfigurable
DescribeLogDirsRequest
Kafka Commons
Cluster
Cluster (deprecated)
ClusterConnectionStates
ClusterResourceListener (and ClusterResourceListeners Collection)
NotificationHandler Contract
ZkNodeChangeNotificationListener
MetadataRequest
MetadataResponse
FindCoordinatorRequest
FindCoordinatorResponse
Kafka Security
SimpleAclAuthorizer
Varia / Misc
KafkaScheduler
Scheduler
ZooKeeperClient
KafkaZkClient — Higher-Level Kafka-Specific ZooKeeper Client
AdminZkClient
ZkAclChangeStore
Kafka Connect
WorkerGroupMember
ConnectDistributed
Kafka Demos
Demo: Kafka Controller Election
Appendix
Further reading or watching
Published with GitBook
ReplicationQuotaManager
ReplicationQuotaManager
ReplicationQuotaManager
is…FIXME
results matching "
"
No results matching "
"