Skip to content

The Internals of Apache Kafka

GetOffsetShell

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
- Controller Election
- Dynamic Broker Configuration
  Dynamic Broker Configuration
- Dynamic Configuration
  Dynamic Configuration
  - Reconfigurable
- Kafka Raft (KRaft)
  Kafka Raft (KRaft)
- Log Cleanup
  Log Cleanup
- Metadata
  Metadata
- Metrics
  Metrics
- 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
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
Controller
Controller
- AbstractControllerBrokerRequestBatch
- ControllerBrokerRequestBatch
- ControllerChannelManager
- ControllerContext
- ControllerEvents
  ControllerEvents
- ControllerEventManager
- ControllerEventProcessor
- Controller Requests
  Controller Requests
  - AbstractControlRequest
  - LeaderAndIsrRequest
- ControllerState
- ControllerEventThread
- Election
- KafkaController
- PartitionLeaderElectionAlgorithms
- PartitionStateMachine
- QueuedEvent
- ReplicaStateMachine
- TopicDeletionManager
- ZkPartitionStateMachine
- ZkReplicaStateMachine
Broker
Broker
Clients
Clients
- Admin
  Admin
- Consumers
  Consumers
- CommonClientConfigs
- KafkaClient
- Metadata
- MetadataUpdater
- NetworkClient
- NetworkClientUtils
- Producers
  Producers
- Serde
- Serdes
Tools
Tools
- kafka-acls
  kafka-acls
- 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 GetOffsetShell
    Table of contents
    
    Launching Application
    
    fetchOffsets
- 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
- kafka-storage
  kafka-storage
  - StorageTool
Misc
Misc
Demos
Demos

Table of contents

Launching Application
fetchOffsets

Apache Kafka
Tools
kafka-get-offsets

GetOffsetShell¶

Launching Application¶

main(
  args: Array[String]): Unit

main fetchOffsets.

fetchOffsets¶

fetchOffsets(
  args: Array[String]): Unit

fetchOffsets...FIXME

Copyright © 2023 Jacek Laskowski

Made with Material for MkDocs Insiders