1. kafka
   1. (object)
      Kafka
   1. kafka.admin
      1. (class)AdminOperationException
      2. (object)
         AdminUtils
      3. (object)(class)PreferredReplicaLeaderElectionCommand
      4. (object)
         ReassignmentCompleted
      5. (object)
         ReassignmentFailed
      6. (object)
         ReassignmentInProgress
      7. (trait)ReassignmentStatus
      8. (object)(class)ReassignPartitionsCommand
      9. (object)
         TopicCommand
   2. kafka.api
      1. (object)
         ApiUtils
      2. (object)(case class)ConsumerMetadataRequest
      3. (object)(case class)ConsumerMetadataResponse
      4. (object)(case class)ControlledShutdownRequest
      5. (object)(case class)ControlledShutdownResponse
      6. (object)(case class)FetchRequest
      7. (class)FetchRequestBuilder
      8. (object)(case class)FetchResponse
      9. (object)(case class)FetchResponsePartitionData
      10. (class)FetchResponseSend
      11. (object)(case class)HeartbeatRequestAndHeader
      12. (object)(case class)HeartbeatResponseAndHeader
      13. (object)(case class)JoinGroupRequestAndHeader
      14. (object)(case class)JoinGroupResponseAndHeader
      15. (object)(case class)LeaderAndIsr
      16. (object)(case class)LeaderAndIsrRequest
      17. (object)(case class)LeaderAndIsrResponse
      18. (object)(case class)OffsetCommitRequest
      19. (object)(case class)OffsetCommitResponse
      20. (object)(case class)OffsetFetchRequest
      21. (object)(case class)OffsetFetchResponse
      22. (object)(case class)OffsetRequest
      23. (object)(case class)OffsetResponse
      24. (class)PartitionDataSend
      25. (case class)PartitionFetchInfo
      26. (object)(case class)PartitionMetadata
      27. (case class)PartitionOffsetRequestInfo
      28. (case class)PartitionOffsetsResponse
      29. (object)(case class)PartitionStateInfo
      30. (object)(case class)ProducerRequest
      31. (object)(case class)ProducerResponse
      32. (case class)ProducerResponseStatus
      33. (object)
          Request
      34. (object)
          RequestKeys
      35. (class)RequestOrResponse
      36. (object)(case class)StopReplicaRequest
      37. (object)(case class)StopReplicaResponse
      38. (object)(case class)TopicData
      39. (class)TopicDataSend
      40. (object)(case class)TopicMetadata
      41. (object)(case class)TopicMetadataRequest
      42. (object)(case class)TopicMetadataResponse
      43. (object)(case class)UpdateMetadataRequest
      44. (object)(case class)UpdateMetadataResponse
   3. kafka.client
      1. (object)
         ClientUtils
   4. kafka.cluster
      1. (object)(case class)Broker
      2. (class)Partition
      3. (class)Replica
   5. kafka.common
      1. (class)AdminCommandFailedException
      2. (object)
         AppInfo
      3. (class)BrokerNotAvailableException
      4. (case class)ClientIdAllBrokers
      5. (case class)ClientIdAllTopics
      6. (case class)ClientIdAndBroker
      7. (case class)ClientIdAndTopic
      8. (trait)ClientIdBroker
      9. (trait)ClientIdTopic
      10. (trait)Config
      11. (class)ConsumerCoordinatorNotAvailableException
      12. (class)ConsumerRebalanceFailedException
      13. (class)ControllerMovedException
      14. (object)
          ErrorMapping
      15. (class)FailedToSendMessageException
      16. (class)InvalidConfigException
      17. (class)InvalidMessageSizeException
      18. (class)InvalidOffsetException
      19. (class)InvalidTopicException
      20. (class)KafkaException
      21. (class)KafkaStorageException
      22. (class)LeaderElectionNotNeededException
      23. (class)LeaderNotAvailableException
      24. (class)LogCleaningAbortedException
      25. (class)MessageSetSizeTooLargeException
      26. (class)MessageSizeTooLargeException
      27. (class)MessageStreamsExistException
      28. (class)NoBrokersForPartitionException
      29. (class)NoEpochForPartitionException
      30. (class)NoReplicaOnlineException
      31. (class)NotAssignedReplicaException
      32. (class)NotCoordinatorForConsumerException
      33. (class)NotEnoughReplicasAfterAppendException
      34. (class)NotEnoughReplicasException
      35. (class)NotLeaderForPartitionException
      36. (object)(case class)OffsetAndMetadata
      37. (object)(case class)OffsetMetadataAndError
      38. (class)OffsetMetadataTooLargeException
      39. (class)OffsetOutOfRangeException
      40. (class)OffsetsLoadInProgressException
      41. (class)QueueFullException
      42. (class)ReplicaNotAvailableException
      43. (class)RequestTimedOutException
      44. (class)StateChangeFailedException
      45. (class)ThreadShutdownException
      46. (object)
          Topic
      47. (case class)TopicAndPartition
      48. (class)TopicExistsException
      49. (class)UnavailableProducerException
      50. (class)UnknownCodecException
      51. (class)UnknownException
      52. (class)UnknownMagicByteException
      53. (class)UnknownTopicOrPartitionException
   6. kafka.consumer
      1. (class)AssignmentContext
      2. (case class)Blacklist
      3. (object)
         Consumer
      4. (object)(class)ConsumerConfig
      5. (trait)ConsumerConnector
      6. (class)ConsumerFetcherManager
      7. (class)ConsumerFetcherThread
      8. (class)ConsumerIterator
      9. (case class)ConsumerThreadId
      10. (class)ConsumerTimeoutException
      11. (class)ConsumerTopicMetrics
      12. (class)ConsumerTopicStats
      13. (object)
          ConsumerTopicStatsRegistry
      14. (case class)FetchedDataChunk
      15. (class)FetchRequestAndResponseMetrics
      16. (class)FetchRequestAndResponseStats
      17. (object)
          FetchRequestAndResponseStatsRegistry
      18. (class)KafkaStream
      19. (object)(trait)PartitionAssignor
      20. (object)(class)PartitionTopicInfo
      21. (class)RangeAssignor
      22. (class)RoundRobinAssignor
      23. (class)SimpleConsumer
      24. (trait)TopicEventHandler
      25. (class)TopicFilter
      26. (case class)Whitelist
      27. (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)KafkaController
      9. (case class)LeaderIsrAndControllerEpoch
      10. (object)
          NewPartition
      11. (object)
          NewReplica
      12. (object)
          NonExistentPartition
      13. (object)
          NonExistentReplica
      14. (class)NoOpLeaderSelector
      15. (object)
          OfflinePartition
      16. (class)OfflinePartitionLeaderSelector
      17. (object)
          OfflineReplica
      18. (object)
          OnlinePartition
      19. (object)
          OnlineReplica
      20. (case class)PartitionAndReplica
      21. (trait)PartitionLeaderSelector
      22. (class)PartitionsReassignedListener
      23. (trait)PartitionState
      24. (class)PartitionStateMachine
      25. (class)PreferredReplicaElectionListener
      26. (class)PreferredReplicaPartitionLeaderSelector
      27. (class)ReassignedPartitionLeaderSelector
      28. (case class)ReassignedPartitionsContext
      29. (class)ReassignedPartitionsIsrChangeListener
      30. (object)
          ReplicaDeletionIneligible
      31. (object)
          ReplicaDeletionStarted
      32. (object)
          ReplicaDeletionSuccessful
      33. (trait)ReplicaState
      34. (class)ReplicaStateMachine
      35. (class)RequestSendThread
      36. (case class)StopReplicaRequestInfo
      37. (class)TopicDeletionManager
   8. kafka.javaapi
      1. (object)(class)ConsumerMetadataResponse
      2. (class)FetchRequest
      3. (class)FetchResponse
      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. (class)SimpleConsumer
      2. kafka.javaapi.message
         1. (class)ByteBufferMessageSet
         2. (class)MessageSet
      3. kafka.javaapi.producer
         1. (class)Producer
   9. kafka.log
      1. (case class)CleanerConfig
      2. (object)
         Defaults
      3. (class)FileMessageSet
      4. (object)(class)Log
      5. (class)LogCleaner
      6. (object)(case class)LogConfig
      7. (object)
         LogFlushStats
      8. (class)LogManager
      9. (class)LogSegment
      10. (class)OffsetIndex
      11. (trait)OffsetMap
      12. (case class)OffsetPosition
      13. (class)SkimpyOffsetMap
   10. kafka.message
       1. (class)ByteBufferBackedInputStream
       2. (object)(class)ByteBufferMessageSet
       3. (object)(trait)CompressionCodec
       4. (object)
          CompressionFactory
       5. (object)
          DefaultCompressionCodec
       6. (object)
          GZIPCompressionCodec
       7. (class)InvalidMessageException
       8. (object)
          LZ4CompressionCodec
       9. (object)(class)Message
       10. (case class)MessageAndMetadata
       11. (case class)MessageAndOffset
       12. (class)MessageLengthException
       13. (object)(class)MessageSet
       14. (object)
           NoCompressionCodec
       15. (object)
           SnappyCompressionCodec
   11. kafka.metrics
       1. (class)KafkaMetricsConfig
       2. (object)(trait)KafkaMetricsGroup
       3. (object)(trait)KafkaMetricsReporter
       4. (trait)KafkaMetricsReporterMBean
       5. (class)KafkaTimer
   12. kafka.network
       1. (object)(class)BlockingChannel
       2. (trait)ConnectionConfig
       3. (class)ConnectionQuotas
       4. (class)InvalidRequestException
       5. (class)MultiSend
       6. (trait)Receive
       7. (object)(class)RequestChannel
       8. (object)(class)RequestMetrics
       9. (trait)Send
       10. (class)SocketServer
       11. (class)TooManyConnectionsException
   13. kafka.producer
       1. (trait)BaseProducer
       2. (class)BrokerPartitionInfo
       3. (class)ByteArrayPartitioner
       4. (class)DefaultPartitioner
       5. (class)KafkaLog4jAppender
       6. (case class)KeyedMessage
       7. (class)NewShinyProducer
       8. (class)OldProducer
       9. (case class)PartitionAndLeader
       10. (trait)Partitioner
       11. (class)Producer
       12. (class)ProducerClosedException
       13. (object)(class)ProducerConfig
       14. (object)(class)ProducerPool
       15. (class)ProducerRequestMetrics
       16. (class)ProducerRequestStats
       17. (object)
           ProducerRequestStatsRegistry
       18. (class)ProducerStats
       19. (object)
           ProducerStatsRegistry
       20. (class)ProducerTopicMetrics
       21. (class)ProducerTopicStats
       22. (object)
           ProducerTopicStatsRegistry
       23. (object)(class)SyncProducer
       24. (object)(class)SyncProducerConfig
       25. (trait)SyncProducerConfigShared
       1. kafka.producer.async
          1. (trait)AsyncProducerConfig
          2. (class)DefaultEventHandler
          3. (trait)EventHandler
          4. (class)IllegalQueueStateException
          5. (class)MissingConfigException
          6. (class)ProducerSendThread
   14. kafka.serializer
       1. (trait)Decoder
       2. (class)DefaultDecoder
       3. (class)DefaultEncoder
       4. (trait)Encoder
       5. (class)NullEncoder
       6. (class)StringDecoder
       7. (class)StringEncoder
   15. kafka.server
       1. (class)AbstractFetcherManager
       2. (class)AbstractFetcherThread
       3. (case class)BrokerAndFetcherId
       4. (case class)BrokerAndInitialOffset
       5. (object)
          BrokerShuttingDown
       6. (case class)BrokerState
       7. (trait)BrokerStates
       8. (class)BrokerTopicMetrics
       9. (object)
          BrokerTopicStats
       10. (case class)ClientIdTopicPartition
       11. (class)DelayedFetch
       12. (class)DelayedProduce
       13. (case class)DelayedProduceResponseStatus
       14. (class)DelayedRequest
       15. (case class)FetchDataInfo
       16. (class)FetcherLagMetrics
       17. (class)FetcherLagStats
       18. (class)FetcherStats
       19. (class)FetchRequestPurgatory
       20. (case class)GroupTopicPartition
       21. (class)KafkaApis
       22. (class)KafkaConfig
       23. (class)KafkaHealthcheck
       24. (class)KafkaRequestHandler
       25. (class)KafkaRequestHandlerPool
       26. (class)KafkaServer
       27. (class)KafkaServerStartable
       28. (trait)LeaderElector
       29. (object)(case class)LogOffsetMetadata
       30. (object)
           NotRunning
       31. (class)OffsetCheckpoint
       32. (object)(class)OffsetManager
       33. (object)(case class)OffsetManagerConfig
       34. (case class)PartitionDataAndOffset
       35. (object)
           PendingControlledShutdown
       36. (class)ProducerRequestPurgatory
       37. (object)
           RecoveringFromUncleanShutdown
       38. (class)ReplicaFetcherManager
       39. (class)ReplicaFetcherThread
       40. (object)(class)ReplicaManager
       41. (class)RequestPurgatory
       42. (object)
           RunningAsBroker
       43. (object)
           RunningAsController
       44. (object)
           Starting
       45. (class)TopicConfigManager
       46. (class)ZookeeperLeaderElector
   16. 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)
          ExportZkOffsets
       9. (object)
          GetOffsetShell
       10. (object)
           ImportZkOffsets
       11. (object)
           JmxTool
       12. (object)(class)KafkaMigrationTool
       13. (trait)MessageFormatter
       14. (object)
           MirrorMaker
       15. (class)NoOpMessageFormatter
       16. (class)PerfConfig
       17. (object)
           ProducerPerformance
       18. (object)
           ReplayLogProducer
       19. (object)
           ReplicaVerificationTool
       20. (object)
           SimpleConsumerPerformance
       21. (object)
           SimpleConsumerShell
       22. (object)
           StateChangeLogMerger
       23. (object)
           TestEndToEndLatency
       24. (object)
           TestLogCleaning
       25. (case class)TestRecord
       26. (object)
           UpdateOffsetsInZK
       27. (object)
           VerifyConsumerRebalance
       28. (object)(class)ZooKeeperMainWrapper
   17. kafka.utils
       1. (object)
          CommandLineUtils
       2. (class)Crc32
       3. (class)DelayedItem
       4. (object)
          DONE
       5. (object)
          FAILED
       6. (class)FileLock
       7. (class)immutable
       8. (class)IteratorTemplate
       9. (object)
          Json
       10. (class)KafkaScheduler
       11. (object)
           Log4jController
       12. (trait)Logging
       13. (object)
           Mx4jLoader
       14. (class)nonthreadsafe
       15. (object)
           NOT_READY
       16. (object)
           Os
       17. (class)Pool
       18. (object)
           READY
       19. (object)
           ReplicationUtils
       20. (trait)Scheduler
       21. (class)ShutdownableThread
       22. (class)State
       23. (object)
           SystemTime
       24. (class)threadsafe
       25. (object)(class)Throttler
       26. (object)(trait)Time
       27. (object)
           ToolsUtils
       28. (object)
           Utils
       29. (class)VerifiableProperties
       30. (class)ZKConfig
       31. (class)ZKGroupDirs
       32. (class)ZKGroupTopicDirs
       33. (object)
           ZKStringSerializer
       34. (object)
           ZkUtils