kafka

1. (object)
   Kafka

1. kafka.api

   1. (object)(class)FetchRequest
   2. (object)(class)MultiFetchRequest
   3. (class)MultiFetchResponse
   4. (object)(class)MultiProducerRequest
   5. (object)(class)OffsetRequest
   6. (object)(class)ProducerRequest
   7. (object)
      RequestKeys

2. kafka.cluster

   1. (object)(class)Partition

3. kafka.common

   1. (class)ConsumerRebalanceFailedException
   2. (object)
      ErrorMapping
   3. (class)InvalidConfigException
   4. (class)InvalidMessageSizeException
   5. (class)InvalidPartitionException
   6. (class)InvalidTopicException
   7. (class)MessageSizeTooLargeException
   8. (class)NoBrokersForPartitionException
   9. (class)OffsetOutOfRangeException
   10. (class)UnavailableProducerException
   11. (class)UnknownCodecException
   12. (class)UnknownException
   13. (class)UnknownMagicByteException

4. kafka.consumer

   1. (class)Blacklist
   2. (object)
      ConsoleConsumer
   3. (object)
      Consumer
   4. (object)(class)ConsumerConfig
   5. (trait)ConsumerConnector
   6. (class)ConsumerIterator
   7. (class)ConsumerTimeoutException
   8. (object)(class)ConsumerTopicStat
   9. (trait)ConsumerTopicStatMBean
   10. (class)FetcherRunnable
   11. (class)KafkaStream
   12. (class)SimpleConsumer
   13. (object)(class)SimpleConsumerStats
   14. (trait)SimpleConsumerStatsMBean
   15. (trait)TopicEventHandler
   16. (class)TopicFilter
   17. (class)Whitelist
   18. (trait)ZookeeperConsumerConnectorMBean
   19. (class)ZookeeperTopicEventWatcher

   1. kafka.consumer.storage

      1. (class)MemoryOffsetStorage
      2. (trait)OffsetStorage

      1. kafka.consumer.storage.sql

         1. (class)OracleOffsetStorage

5. kafka.javaapi

   1. (class)MultiFetchResponse
   2. (class)ProducerRequest

   1. kafka.javaapi.consumer

      1. (object)(trait)ConsumerConnector
      2. (class)SimpleConsumer

   2. kafka.javaapi.message

      1. (class)ByteBufferMessageSet
      2. (class)MessageSet

   3. kafka.javaapi.producer

      1. (class)Producer
      2. (class)ProducerData
      3. (class)SyncProducer

      1. kafka.javaapi.producer.async

         1. (object)(trait)CallbackHandler
         2. (object)(trait)EventHandler

6. kafka.log

   1. (class)LogStats
   2. (trait)LogStatsMBean

7. kafka.message

   1. (class)ByteBufferBackedInputStream
   2. (class)ByteBufferMessageSet
   3. (object)(trait)CompressionCodec
   4. (class)CompressionFacade
   5. (object)
      CompressionFactory
   6. (object)
      CompressionUtils
   7. (object)
      DefaultCompressionCodec
   8. (class)FileMessageSet
   9. (class)GZIPCompression
   10. (object)
       GZIPCompressionCodec
   11. (class)InvalidMessageException
   12. (object)(class)LogFlushStats
   13. (trait)LogFlushStatsMBean
   14. (object)(class)Message
   15. (class)MessageAndMetadata
   16. (class)MessageAndOffset
   17. (class)MessageLengthException
   18. (object)(class)MessageSet
   19. (object)
       NoCompressionCodec
   20. (class)SnappyCompression
   21. (object)
       SnappyCompressionCodec

8. kafka.network

   1. (trait)ConnectionConfig
   2. (class)InvalidRequestException
   3. (class)MultiSend
   4. (class)SocketServer
   5. (class)SocketServerStats
   6. (trait)SocketServerStatsMBean

9. kafka.producer

   1. (trait)BrokerPartitionInfo
   2. (object)
      ConsoleProducer
   3. (class)KafkaLog4jAppender
   4. (trait)Partitioner
   5. (class)Producer
   6. (class)ProducerConfig
   7. (class)ProducerData
   8. (class)ProducerPool
   9. (object)(class)SyncProducer
   10. (class)SyncProducerConfig
   11. (trait)SyncProducerConfigShared
   12. (object)(class)SyncProducerStats
   13. (trait)SyncProducerStatsMBean

   1. kafka.producer.async

      1. (object)
         AsyncProducer
      2. (class)AsyncProducerConfig
      3. (trait)AsyncProducerConfigShared
      4. (class)AsyncProducerInterruptedException
      5. (class)AsyncProducerQueueSizeStats
      6. (trait)AsyncProducerQueueSizeStatsMBean
      7. (object)(class)AsyncProducerStats
      8. (trait)AsyncProducerStatsMBean
      9. (trait)CallbackHandler
      10. (trait)EventHandler
      11. (class)IllegalQueueStateException
      12. (class)MissingConfigException
      13. (class)QueueClosedException
      14. (class)QueueFullException
      15. (class)QueueItem

10. kafka.serializer

    1. (trait)Decoder
    2. (class)DefaultDecoder
    3. (class)DefaultEncoder
    4. (trait)Encoder
    5. (class)StringDecoder
    6. (class)StringEncoder

11. kafka.server

    1. (object)(class)BrokerTopicStat
    2. (trait)BrokerTopicStatMBean
    3. (class)KafkaConfig
    4. (class)KafkaServer
    5. (class)KafkaServerStartable
    6. (class)KafkaZooKeeper

12. kafka.tools

    1. (object)
       ConsumerOffsetChecker
    2. (object)
       ConsumerShell
    3. (object)
       DumpLogSegments
    4. (object)
       ExportZkOffsets
    5. (object)
       GetOffsetShell
    6. (object)
       ImportZkOffsets
    7. (object)
       JmxTool
    8. (object)
       MirrorMaker
    9. (object)
       ProducerShell
    10. (object)
        ReplayLogProducer
    11. (object)
        SimpleConsumerShell
    12. (object)
        VerifyConsumerRebalance
    13. (class)ZKConsumerThread

13. kafka.utils

    1. (class)DelayedItem
    2. (object)
       DONE
    3. (object)
       FAILED
    4. (class)immutable
    5. (class)IteratorTemplate
    6. (class)KafkaScheduler
    7. (trait)Logging
    8. (class)MockTime
    9. (object)
       Mx4jLoader
    10. (class)nonthreadsafe
    11. (object)
        NOT_READY
    12. (class)Pool
    13. (trait)Range
    14. (object)
        READY
    15. (class)SnapshotStats
    16. (class)State
    17. (object)
        SystemTime
    18. (class)threadsafe
    19. (object)(class)Throttler
    20. (object)(trait)Time
    21. (object)
        UpdateOffsetsInZK
    22. (object)
        Utils
    23. (class)ZKConfig
    24. (class)ZKGroupDirs
    25. (class)ZKGroupTopicDirs
    26. (object)
        ZKStringSerializer
    27. (object)
        ZkUtils