1. kafka
   1. (object)
      Kafka
   1. kafka.admin
      1. (object)
         AclCommand
      2. (object)(class)AdminClient
      3. (class)AdminOperationException
      4. (object)
         AdminUtils
      5. (object)
         ConfigCommand
      6. (object)
         ConsumerGroupCommand
      7. (object)(class)PreferredReplicaLeaderElectionCommand
      8. (object)
         ReassignmentCompleted
      9. (object)
         ReassignmentFailed
      10. (object)
          ReassignmentInProgress
      11. (trait)ReassignmentStatus
      12. (object)(class)ReassignPartitionsCommand
      13. (object)
          TopicCommand
      14. (object)(class)ZkSecurityMigrator
   2. kafka.api
      1. (object)
         ApiUtils
      2. (object)(trait)ApiVersion
      3. (object)(case class)ControlledShutdownRequest
      4. (object)(case class)ControlledShutdownResponse
      5. (object)(case class)FetchRequest
      6. (class)FetchRequestBuilder
      7. (object)(case class)FetchResponse
      8. (object)(case class)FetchResponsePartitionData
      9. (class)FetchResponseSend
      10. (object)(case class)GroupCoordinatorRequest
      11. (object)(case class)GroupCoordinatorResponse
      12. (object)
          KAFKA_080
      13. (object)
          KAFKA_081
      14. (object)
          KAFKA_082
      15. (object)
          KAFKA_090
      16. (object)(case class)LeaderAndIsr
      17. (object)(case class)LeaderAndIsrRequest
      18. (object)(case class)LeaderAndIsrResponse
      19. (object)(case class)OffsetCommitRequest
      20. (object)(case class)OffsetCommitResponse
      21. (object)(case class)OffsetFetchRequest
      22. (object)(case class)OffsetFetchResponse
      23. (object)(case class)OffsetRequest
      24. (object)(case class)OffsetResponse
      25. (class)PartitionDataSend
      26. (case class)PartitionFetchInfo
      27. (object)(case class)PartitionMetadata
      28. (case class)PartitionOffsetRequestInfo
      29. (case class)PartitionOffsetsResponse
      30. (object)(case class)PartitionStateInfo
      31. (object)(case class)ProducerRequest
      32. (object)(case class)ProducerResponse
      33. (case class)ProducerResponseStatus
      34. (object)
          Request
      35. (object)
          RequestKeys
      36. (class)RequestOrResponse
      37. (object)(case class)StopReplicaRequest
      38. (object)(case class)StopReplicaResponse
      39. (object)(case class)TopicData
      40. (class)TopicDataSend
      41. (object)(case class)TopicMetadata
      42. (object)(case class)TopicMetadataRequest
      43. (object)(case class)TopicMetadataResponse
      44. (object)(case class)UpdateMetadataRequest
      45. (object)(case class)UpdateMetadataResponse
   3. kafka.client
      1. (object)
         ClientUtils
   4. kafka.cluster
      1. (object)(case class)Broker
      2. (object)(case class)BrokerEndPoint
      3. (object)(case class)EndPoint
      4. (class)Partition
      5. (class)Replica
   5. kafka.common
      1. (class)AdminCommandFailedException
      2. (object)
         AppInfo
      3. (class)AuthorizationException
      4. (trait)BaseEnum
      5. (class)BrokerEndPointNotAvailableException
      6. (class)BrokerNotAvailableException
      7. (case class)ClientIdAllBrokers
      8. (case class)ClientIdAllTopics
      9. (case class)ClientIdAndBroker
      10. (case class)ClientIdAndTopic
      11. (trait)ClientIdBroker
      12. (trait)ClientIdTopic
      13. (class)ClusterAuthorizationException
      14. (trait)Config
      15. (class)ConsumerCoordinatorNotAvailableException
      16. (class)ConsumerRebalanceFailedException
      17. (class)ControllerMovedException
      18. (object)
          ErrorMapping
      19. (class)FailedToSendMessageException
      20. (class)GenerateBrokerIdException
      21. (class)GroupAuthorizationException
      22. (class)InconsistentBrokerIdException
      23. (class)InvalidConfigException
      24. (class)InvalidMessageSizeException
      25. (class)InvalidOffsetException
      26. (class)InvalidTopicException
      27. (class)KafkaException
      28. (class)KafkaStorageException
      29. (class)LeaderElectionNotNeededException
      30. (class)LeaderNotAvailableException
      31. (class)LogCleaningAbortedException
      32. (class)MessageSetSizeTooLargeException
      33. (class)MessageSizeTooLargeException
      34. (class)MessageStreamsExistException
      35. (class)NoBrokersForPartitionException
      36. (class)NoEpochForPartitionException
      37. (class)NoReplicaOnlineException
      38. (class)NotAssignedReplicaException
      39. (class)NotCoordinatorForConsumerException
      40. (class)NotEnoughReplicasAfterAppendException
      41. (class)NotEnoughReplicasException
      42. (trait)NotificationHandler
      43. (class)NotLeaderForPartitionException
      44. (object)(case class)OffsetAndMetadata
      45. (object)(case class)OffsetMetadata
      46. (object)(case class)OffsetMetadataAndError
      47. (class)OffsetMetadataTooLargeException
      48. (class)OffsetOutOfRangeException
      49. (class)OffsetsLoadInProgressException
      50. (class)QueueFullException
      51. (class)ReplicaNotAvailableException
      52. (class)RequestTimedOutException
      53. (class)StateChangeFailedException
      54. (class)StreamEndException
      55. (class)ThreadShutdownException
      56. (object)
          Topic
      57. (class)TopicAlreadyMarkedForDeletionException
      58. (case class)TopicAndPartition
      59. (class)TopicAuthorizationException
      60. (class)TopicExistsException
      61. (class)UnavailableProducerException
      62. (class)UnknownCodecException
      63. (class)UnknownException
      64. (class)UnknownMagicByteException
      65. (class)UnknownTopicOrPartitionException
      66. (class)ZkNodeChangeNotificationListener
   6. kafka.consumer
      1. (class)AssignmentContext
      2. (trait)BaseConsumer
      3. (case class)BaseConsumerRecord
      4. (case class)Blacklist
      5. (object)
         Consumer
      6. (object)(class)ConsumerConfig
      7. (trait)ConsumerConnector
      8. (class)ConsumerFetcherManager
      9. (object)(class)ConsumerFetcherThread
      10. (class)ConsumerIterator
      11. (case class)ConsumerThreadId
      12. (class)ConsumerTimeoutException
      13. (class)ConsumerTopicMetrics
      14. (class)ConsumerTopicStats
      15. (object)
          ConsumerTopicStatsRegistry
      16. (case class)FetchedDataChunk
      17. (class)FetchRequestAndResponseMetrics
      18. (class)FetchRequestAndResponseStats
      19. (object)
          FetchRequestAndResponseStatsRegistry
      20. (class)KafkaStream
      21. (class)NewShinyConsumer
      22. (class)OldConsumer
      23. (object)(trait)PartitionAssignor
      24. (object)(class)PartitionTopicInfo
      25. (class)RangeAssignor
      26. (class)RoundRobinAssignor
      27. (class)SimpleConsumer
      28. (trait)TopicEventHandler
      29. (class)TopicFilter
      30. (case class)Whitelist
      31. (class)ZookeeperTopicEventWatcher
   7. kafka.controller
      1. (object)(class)Callbacks
      2. (class)ControlledShutdownLeaderSelector
      3. (class)ControllerBrokerRequestBatch
      4. (case class)ControllerBrokerStateInfo
      5. (class)ControllerChannelManager
      6. (class)ControllerContext
      7. (object)
         ControllerStats
      8. (object)(class)IsrChangeNotificationListener
      9. (object)(class)KafkaController
      10. (case class)LeaderIsrAndControllerEpoch
      11. (object)
          NewPartition
      12. (object)
          NewReplica
      13. (object)
          NonExistentPartition
      14. (object)
          NonExistentReplica
      15. (class)NoOpLeaderSelector
      16. (object)
          OfflinePartition
      17. (class)OfflinePartitionLeaderSelector
      18. (object)
          OfflineReplica
      19. (object)
          OnlinePartition
      20. (object)
          OnlineReplica
      21. (case class)PartitionAndReplica
      22. (trait)PartitionLeaderSelector
      23. (class)PartitionsReassignedListener
      24. (trait)PartitionState
      25. (class)PartitionStateMachine
      26. (class)PreferredReplicaElectionListener
      27. (class)PreferredReplicaPartitionLeaderSelector
      28. (case class)QueueItem
      29. (class)ReassignedPartitionLeaderSelector
      30. (case class)ReassignedPartitionsContext
      31. (class)ReassignedPartitionsIsrChangeListener
      32. (object)
          ReplicaDeletionIneligible
      33. (object)
          ReplicaDeletionStarted
      34. (object)
          ReplicaDeletionSuccessful
      35. (trait)ReplicaState
      36. (class)ReplicaStateMachine
      37. (class)RequestSendThread
      38. (case class)StopReplicaRequestInfo
      39. (class)TopicDeletionManager
   8. kafka.coordinator
      1. (trait)BaseKey
      2. (case class)DelayedStore
      3. (case class)GroupConfig
      4. (object)(class)GroupCoordinator
      5. (case class)GroupMetadataKey
      6. (object)(class)GroupMetadataManager
      7. (case class)GroupOverview
      8. (case class)GroupSummary
      9. (case class)GroupTopicPartition
      10. (case class)JoinGroupResult
      11. (case class)MemberSummary
      12. (object)(case class)OffsetConfig
      13. (case class)OffsetKey
   9. kafka.javaapi
      1. (class)FetchRequest
      2. (class)FetchResponse
      3. (object)(class)GroupCoordinatorResponse
      4. (class)OffsetCommitRequest
      5. (object)(class)OffsetCommitResponse
      6. (class)OffsetFetchRequest
      7. (object)(class)OffsetFetchResponse
      8. (class)OffsetRequest
      9. (class)OffsetResponse
      10. (class)PartitionMetadata
      11. (class)TopicMetadata
      12. (class)TopicMetadataRequest
      13. (class)TopicMetadataResponse
      1. kafka.javaapi.consumer
         1. (trait)ConsumerConnector
         2. (trait)ConsumerRebalanceListener
         3. (class)SimpleConsumer
      2. kafka.javaapi.message
         1. (class)ByteBufferMessageSet
         2. (class)MessageSet
      3. kafka.javaapi.producer
         1. (class)Producer
   10. kafka.log
       1. (case class)CleanerConfig
       2. (object)
          Defaults
       3. (object)(class)FileMessageSet
       4. (object)(class)Log
       5. (object)(case class)LogAppendInfo
       6. (class)LogCleaner
       7. (object)(case class)LogConfig
       8. (object)
          LogFlushStats
       9. (class)LogManager
       10. (class)LogSegment
       11. (class)OffsetIndex
       12. (trait)OffsetMap
       13. (case class)OffsetPosition
       14. (class)SkimpyOffsetMap
   11. kafka.message
       1. (object)(trait)BrokerCompressionCodec
       2. (class)BufferingOutputStream
       3. (class)ByteBufferBackedInputStream
       4. (object)(class)ByteBufferMessageSet
       5. (object)(trait)CompressionCodec
       6. (object)
          CompressionFactory
       7. (object)
          DefaultCompressionCodec
       8. (object)
          GZIPCompressionCodec
       9. (class)InvalidMessageException
       10. (object)
           LZ4CompressionCodec
       11. (object)(class)Message
       12. (case class)MessageAndMetadata
       13. (case class)MessageAndOffset
       14. (class)MessageLengthException
       15. (object)(class)MessageSet
       16. (class)MessageWriter
       17. (object)
           NoCompressionCodec
       18. (object)
           ProducerCompressionCodec
       19. (object)
           SnappyCompressionCodec
       20. (object)
           UncompressedCodec
   12. kafka.metrics
       1. (class)KafkaMetricsConfig
       2. (object)(trait)KafkaMetricsGroup
       3. (object)(trait)KafkaMetricsReporter
       4. (trait)KafkaMetricsReporterMBean
       5. (class)KafkaTimer
   13. kafka.network
       1. (object)(class)BlockingChannel
       2. (trait)ConnectionConfig
       3. (class)ConnectionQuotas
       4. (class)InvalidRequestException
       5. (object)(class)RequestChannel
       6. (object)(class)RequestMetrics
       7. (object)(class)RequestOrResponseSend
       8. (class)SocketServer
       9. (class)TooManyConnectionsException
   14. kafka.producer
       1. (trait)BaseProducer
       2. (class)BrokerPartitionInfo
       3. (class)ByteArrayPartitioner
       4. (class)DefaultPartitioner
       5. (case class)KeyedMessage
       6. (class)NewShinyProducer
       7. (class)OldProducer
       8. (case class)PartitionAndLeader
       9. (trait)Partitioner
       10. (class)Producer
       11. (class)ProducerClosedException
       12. (object)(class)ProducerConfig
       13. (object)(class)ProducerPool
       14. (class)ProducerRequestMetrics
       15. (class)ProducerRequestStats
       16. (object)
           ProducerRequestStatsRegistry
       17. (class)ProducerStats
       18. (object)
           ProducerStatsRegistry
       19. (class)ProducerTopicMetrics
       20. (class)ProducerTopicStats
       21. (object)
           ProducerTopicStatsRegistry
       22. (object)(class)SyncProducer
       23. (object)(class)SyncProducerConfig
       24. (trait)SyncProducerConfigShared
       1. kafka.producer.async
          1. (trait)AsyncProducerConfig
          2. (class)DefaultEventHandler
          3. (trait)EventHandler
          4. (class)IllegalQueueStateException
          5. (class)MissingConfigException
          6. (class)ProducerSendThread
   15. kafka.security
       1. kafka.security.auth
          1. (object)(case class)Acl
          2. (object)
             All
          3. (object)
             Allow
          4. (object)
             Alter
          5. (trait)Authorizer
          6. (object)
             Cluster
          7. (object)
             ClusterAction
          8. (object)
             Create
          9. (object)
             Delete
          10. (object)
              Deny
          11. (object)
              Describe
          12. (object)
              Group
          13. (object)(trait)Operation
          14. (object)(trait)PermissionType
          15. (object)
              Read
          16. (object)(case class)Resource
          17. (object)(trait)ResourceType
          18. (object)(class)SimpleAclAuthorizer
          19. (object)
              Topic
          20. (object)
              Write
   16. kafka.serializer
       1. (trait)Decoder
       2. (class)DefaultDecoder
       3. (class)DefaultEncoder
       4. (trait)Encoder
       5. (class)NullEncoder
       6. (class)StringDecoder
       7. (class)StringEncoder
   17. kafka.server
       1. (class)AbstractFetcherManager
       2. (object)(class)AbstractFetcherThread
       3. (case class)BecomeLeaderOrFollowerResult
       4. (case class)BrokerAndFetcherId
       5. (case class)BrokerAndInitialOffset
       6. (case class)BrokerMetadata
       7. (class)BrokerMetadataCheckpoint
       8. (object)
          BrokerShuttingDown
       9. (case class)BrokerState
       10. (trait)BrokerStates
       11. (class)BrokerTopicMetrics
       12. (object)
           BrokerTopicStats
       13. (object)
           ClientConfigOverride
       14. (class)ClientIdConfigHandler
       15. (case class)ClientIdTopicPartition
       16. (class)ClientQuotaManager
       17. (object)(case class)ClientQuotaManagerConfig
       18. (trait)ConfigHandler
       19. (object)
           ConfigType
       20. (object)
           Defaults
       21. (class)DelayedFetch
       22. (object)
           DelayedFetchMetrics
       23. (class)DelayedOperation
       24. (object)(trait)DelayedOperationKey
       25. (class)DelayedOperationPurgatory
       26. (class)DelayedProduce
       27. (object)
           DelayedProduceMetrics
       28. (class)DynamicConfigManager
       29. (case class)FetchDataInfo
       30. (class)FetcherLagMetrics
       31. (class)FetcherLagStats
       32. (class)FetcherStats
       33. (case class)FetchMetadata
       34. (case class)FetchPartitionStatus
       35. (case class)GroupKey
       36. (class)KafkaApis
       37. (object)(case class)KafkaConfig
       38. (class)KafkaHealthcheck
       39. (class)KafkaRequestHandler
       40. (class)KafkaRequestHandlerPool
       41. (object)(class)KafkaServer
       42. (object)(class)KafkaServerStartable
       43. (trait)LeaderElector
       44. (case class)LogAppendResult
       45. (object)(case class)LogOffsetMetadata
       46. (object)(case class)LogReadResult
       47. (case class)MemberKey
       48. (object)
           NotRunning
       49. (class)OffsetCheckpoint
       50. (case class)PartitionFetchState
       51. (object)
           PendingControlledShutdown
       52. (case class)ProduceMetadata
       53. (case class)ProducePartitionStatus
       54. (object)
           RecoveringFromUncleanShutdown
       55. (class)ReplicaFetcherManager
       56. (object)(class)ReplicaFetcherThread
       57. (object)(class)ReplicaManager
       58. (object)
           RunningAsBroker
       59. (object)
           RunningAsController
       60. (object)
           Starting
       61. (class)TopicConfigHandler
       62. (case class)TopicPartitionOperationKey
       63. (class)ZookeeperLeaderElector
   18. kafka.tools
       1. (class)ChecksumMessageFormatter
       2. (object)
          ConsoleConsumer
       3. (object)
          ConsoleProducer
       4. (object)
          ConsumerOffsetChecker
       5. (object)
          ConsumerPerformance
       6. (class)DefaultMessageFormatter
       7. (object)
          DumpLogSegments
       8. (object)
          EndToEndLatency
       9. (object)
          ExportZkOffsets
       10. (object)
           GetOffsetShell
       11. (object)
           ImportZkOffsets
       12. (object)
           JmxTool
       13. (class)KafkaMigrationTool
       14. (trait)MessageFormatter
       15. (object)
           MirrorMaker
       16. (class)NoOpMessageFormatter
       17. (class)PerfConfig
       18. (object)
           ProducerPerformance
       19. (object)
           ReplayLogProducer
       20. (object)
           ReplicaVerificationTool
       21. (object)
           SimpleConsumerPerformance
       22. (object)
           SimpleConsumerShell
       23. (object)
           StateChangeLogMerger
       24. (object)
           UpdateOffsetsInZK
       25. (object)
           VerifyConsumerRebalance
       26. (object)(class)ZooKeeperMainWrapper
   19. kafka.utils
       1. (class)ByteBoundedBlockingQueue
       2. (object)
          CommandLineUtils
       3. (object)
          CoreUtils
       4. (class)DelayedItem
       5. (object)
          DONE
       6. (class)DoublyLinkedList
       7. (class)DoublyLinkedListNode
       8. (object)
          FAILED
       9. (class)FileLock
       10. (class)immutable
       11. (class)IteratorTemplate
       12. (object)
           Json
       13. (class)KafkaScheduler
       14. (object)
           Log4jController
       15. (trait)Logging
       16. (object)
           Mx4jLoader
       17. (object)(class)NetworkClientBlockingOps
       18. (class)nonthreadsafe
       19. (object)
           NOT_READY
       20. (object)
           Os
       21. (class)Pool
       22. (object)
           READY
       23. (object)
           ReplicationUtils
       24. (trait)Scheduler
       25. (class)ShutdownableThread
       26. (class)State
       27. (object)
           SystemTime
       28. (class)threadsafe
       29. (object)(class)Throttler
       30. (object)(trait)Time
       31. (object)
           ToolsUtils
       32. (class)VerifiableProperties
       33. (class)ZKCheckedEphemeral
       34. (class)ZKConfig
       35. (class)ZKGroupDirs
       36. (class)ZKGroupTopicDirs
       37. (object)
           ZkPath
       38. (object)(class)ZkUtils
       1. kafka.utils.timer
          1. (class)Timer
          2. (trait)TimerTask