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. (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