class icon trait icon trait icon trait icon
    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. (class)BrokerNotAvailableException
        3. (case class)ClientIdAndBroker
        4. (case class)ClientIdAndTopic
        5. (trait)Config
        6. (class)ConsumerCoordinatorNotAvailableException
        7. (class)ConsumerRebalanceFailedException
        8. (class)ControllerMovedException
        9. (object)
          ErrorMapping
        10. (class)FailedToSendMessageException
        11. (class)InvalidConfigException
        12. (class)InvalidMessageSizeException
        13. (class)InvalidOffsetException
        14. (class)InvalidTopicException
        15. (class)KafkaException
        16. (class)KafkaStorageException
        17. (class)LeaderElectionNotNeededException
        18. (class)LeaderNotAvailableException
        19. (class)LogCleaningAbortedException
        20. (class)MessageSetSizeTooLargeException
        21. (class)MessageSizeTooLargeException
        22. (class)MessageStreamsExistException
        23. (class)NoBrokersForPartitionException
        24. (class)NoEpochForPartitionException
        25. (class)NoReplicaOnlineException
        26. (class)NotAssignedReplicaException
        27. (class)NotCoordinatorForConsumerException
        28. (class)NotEnoughReplicasAfterAppendException
        29. (class)NotEnoughReplicasException
        30. (class)NotLeaderForPartitionException
        31. (object)(case class)OffsetAndMetadata
        32. (object)(case class)OffsetMetadataAndError
        33. (class)OffsetMetadataTooLargeException
        34. (class)OffsetOutOfRangeException
        35. (class)OffsetsLoadInProgressException
        36. (class)QueueFullException
        37. (class)ReplicaNotAvailableException
        38. (class)RequestTimedOutException
        39. (class)StateChangeFailedException
        40. (class)ThreadShutdownException
        41. (object)
          Topic
        42. (case class)TopicAndPartition
        43. (class)TopicExistsException
        44. (class)UnavailableProducerException
        45. (class)UnknownCodecException
        46. (class)UnknownException
        47. (class)UnknownMagicByteException
        48. (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. (class)ConsumerMetadataResponse
        2. (class)FetchRequest
        3. (class)FetchResponse
        4. (class)OffsetCommitRequest
        5. (class)OffsetCommitResponse
        6. (class)OffsetFetchRequest
        7. (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)ClientIdBrokerTopicPartition
        11. (class)DelayedFetch
        12. (class)DelayedProduce
        13. (case class)DelayedProduceResponseStatus
        14. (class)DelayedRequest
        15. (object)(trait)DelayedRequestKey
        16. (case class)FetchDataInfo
        17. (class)FetcherLagMetrics
        18. (class)FetcherLagStats
        19. (class)FetcherStats
        20. (class)FetchRequestPurgatory
        21. (case class)GroupTopicPartition
        22. (class)KafkaApis
        23. (class)KafkaConfig
        24. (class)KafkaHealthcheck
        25. (class)KafkaRequestHandler
        26. (class)KafkaRequestHandlerPool
        27. (class)KafkaServer
        28. (class)KafkaServerStartable
        29. (trait)LeaderElector
        30. (object)(case class)LogOffsetMetadata
        31. (object)
          NotRunning
        32. (class)OffsetCheckpoint
        33. (object)(class)OffsetManager
        34. (object)(case class)OffsetManagerConfig
        35. (case class)PartitionDataAndOffset
        36. (object)
          PendingControlledShutdown
        37. (class)ProducerRequestPurgatory
        38. (object)
          RecoveringFromUncleanShutdown
        39. (class)ReplicaFetcherManager
        40. (class)ReplicaFetcherThread
        41. (object)(class)ReplicaManager
        42. (class)RequestPurgatory
        43. (object)
          RunningAsBroker
        44. (object)
          RunningAsController
        45. (object)
          Starting
        46. (class)TopicConfigManager
        47. (case class)TopicPartitionRequestKey
        48. (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