1. kafka
      1. (object)
        Kafka
      1. kafka.admin
        1. (object)
          AclCommand
        2. (object)(class)AdminClient
        3. (class)AdminOperationException
        4. (object)
          AdminUtils
        5. (case class)BrokerMetadata
        6. (object)
          ConfigCommand
        7. (object)
          ConsumerGroupCommand
        8. (object)(class)PreferredReplicaLeaderElectionCommand
        9. (object)(trait)RackAwareMode
        10. (object)
          ReassignmentCompleted
        11. (object)
          ReassignmentFailed
        12. (object)
          ReassignmentInProgress
        13. (trait)ReassignmentStatus
        14. (object)(class)ReassignPartitionsCommand
        15. (object)
          TopicCommand
        16. (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_0_10_0_IV0
        13. (object)
          KAFKA_0_8_0
        14. (object)
          KAFKA_0_8_1
        15. (object)
          KAFKA_0_8_2
        16. (object)
          KAFKA_0_9_0
        17. (object)(case class)LeaderAndIsr
        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. (class)RequestOrResponse
        35. (object)(case class)TopicData
        36. (class)TopicDataSend
        37. (object)(case class)TopicMetadata
        38. (object)(case class)TopicMetadataRequest
        39. (object)(case class)TopicMetadataResponse
      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)LongRef
        33. (trait)MessageFormatter
        34. (trait)MessageReader
        35. (class)MessageSetSizeTooLargeException
        36. (class)MessageSizeTooLargeException
        37. (class)MessageStreamsExistException
        38. (class)NoBrokersForPartitionException
        39. (class)NoEpochForPartitionException
        40. (class)NoReplicaOnlineException
        41. (class)NotAssignedReplicaException
        42. (class)NotCoordinatorForConsumerException
        43. (class)NotEnoughReplicasAfterAppendException
        44. (class)NotEnoughReplicasException
        45. (trait)NotificationHandler
        46. (class)NotLeaderForPartitionException
        47. (object)(case class)OffsetAndMetadata
        48. (object)(case class)OffsetMetadata
        49. (object)(case class)OffsetMetadataAndError
        50. (class)OffsetMetadataTooLargeException
        51. (class)OffsetOutOfRangeException
        52. (class)OffsetsLoadInProgressException
        53. (class)QueueFullException
        54. (class)ReplicaNotAvailableException
        55. (class)RequestTimedOutException
        56. (class)StateChangeFailedException
        57. (class)StreamEndException
        58. (class)ThreadShutdownException
        59. (object)
          Topic
        60. (class)TopicAlreadyMarkedForDeletionException
        61. (case class)TopicAndPartition
        62. (class)TopicAuthorizationException
        63. (class)TopicExistsException
        64. (class)UnavailableProducerException
        65. (class)UnknownCodecException
        66. (class)UnknownException
        67. (class)UnknownMagicByteException
        68. (class)UnknownTopicOrPartitionException
        69. (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. (case class)MagicAndTimestamp
        12. (object)(class)Message
        13. (case class)MessageAndMetadata
        14. (case class)MessageAndOffset
        15. (class)MessageLengthException
        16. (object)(class)MessageSet
        17. (class)MessageWriter
        18. (object)
          NoCompressionCodec
        19. (object)
          ProducerCompressionCodec
        20. (object)
          SnappyCompressionCodec
        21. (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
        1. kafka.serializer
          1. (trait)Decoder
          2. (class)DefaultDecoder
          3. (class)DefaultEncoder
          4. (trait)Encoder
          5. (class)NullEncoder
          6. (class)StringDecoder
          7. (class)StringEncoder
        2. 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)(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. (object)(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
        3. 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. (class)LoggingMessageFormatter
          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
        4. kafka.utils
          1. (class)ByteBoundedBlockingQueue
          2. (object)
            CommandLineUtils
          3. (object)
            CoreUtils
          4. (class)DelayedItem
          5. (object)
            DONE
          6. (object)
            FAILED
          7. (class)FileLock
          8. (class)immutable
          9. (class)IteratorTemplate
          10. (object)
            Json
          11. (class)KafkaScheduler
          12. (object)
            Log4jController
          13. (trait)Logging
          14. (object)
            Mx4jLoader
          15. (object)(class)NetworkClientBlockingOps
          16. (class)nonthreadsafe
          17. (object)
            NOT_READY
          18. (object)
            Os
          19. (class)Pool
          20. (object)
            READY
          21. (object)
            ReplicationUtils
          22. (trait)Scheduler
          23. (class)ShutdownableThread
          24. (class)State
          25. (object)
            SystemTime
          26. (class)threadsafe
          27. (object)(class)Throttler
          28. (object)(trait)Time
          29. (object)
            ToolsUtils
          30. (class)VerifiableProperties
          31. (class)ZKCheckedEphemeral
          32. (class)ZKConfig
          33. (class)ZKGroupDirs
          34. (class)ZKGroupTopicDirs
          35. (object)
            ZkPath
          36. (object)(class)ZkUtils
          1. kafka.utils.timer
            1. (class)Timer
            2. (trait)TimerTask