kafka_2.10-0.8.0-javadoc.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka_2.10</artifactId>
	<version>0.8.0</version>
	<classifier>javadoc</classifier>
	<type>javadoc</type>
</dependency>

org.apache.kafka:kafka_2.10:0.8.0

META-INF/MANIFEST.MF
kafka/api/LeaderAndIsr$.html
lib/object_to_type_big.png
kafka/message/SnappyCompressionCodec$.html
kafka/common/ReplicaNotAvailableException.html
kafka/server/ReplicaManager.html
kafka/producer/ProducerTopicStats.html
kafka/message/ByteBufferMessageSet.html
kafka/consumer/PartitionTopicInfo.html
lib/navigation-li-a.png
kafka/consumer/DefaultMessageFormatter.html
kafka/producer/ProducerStatsRegistry$.html
lib/object_diagram.png
lib/filterboxbarbg.png
kafka/consumer/ChecksumMessageFormatter.html
lib/selected-implicits.png
kafka/tools/StateChangeLogMerger$.html
kafka/controller/PreferredReplicaPartitionLeaderSelector.html
kafka/server/RequestPurgatory.html
kafka/controller/KafkaController$SessionExpirationListener.html
kafka/serializer/Decoder.html
kafka/common/BrokerNotAvailableException.html
kafka/javaapi/package.html
kafka/network/package.html
kafka/consumer/ConsoleConsumer$.html
kafka/admin/AddPartitionsCommand$.html
kafka/api/OffsetRequest$.html
kafka/common/TopicAndPartition.html
kafka/common/UnknownException.html
kafka/message/package.html
kafka/metrics/KafkaMetricsReporterMBean.html
kafka/controller/ControllerContext.html
kafka/controller/package.html
kafka/controller/PartitionStateMachine.html
kafka/api/LeaderAndIsrResponse$.html
index/index-b.html
kafka/api/FetchRequest$.html
kafka/producer/ProducerPool$.html
index/index-q.html
kafka/utils/DelayedItem.html
index/index-h.html
kafka/javaapi/TopicMetadata.html
kafka/common/OffsetOutOfRangeException.html
kafka/api/Request$.html
kafka/Kafka$.html
kafka/controller/OfflinePartition$.html
kafka/common/KafkaStorageException.html
lib/defbg-green.gif
lib/jquery.js
kafka/api/PartitionStateInfo.html
kafka/controller/NewReplica$.html
kafka/api/package.html
kafka/common/NotLeaderForPartitionException.html
kafka/log/package.html
kafka/controller/ReassignedPartitionsIsrChangeListener.html
lib/package_big.png
index/index-w.html
index/index-c.html
kafka/producer/SyncProducerConfig$.html
kafka/server/LeaderElector.html
kafka/common/UnknownMagicByteException.html
kafka/message/Message$.html
kafka/api/LeaderAndIsrRequest.html
kafka/common/LeaderElectionNotNeededException.html
kafka/message/CompressionCodec$.html
kafka/api/ControlledShutdownResponse.html
kafka/utils/Utils$.html
kafka/javaapi/FetchRequest.html
kafka/producer/ConsoleProducer$$LineMessageReader.html
kafka/common/NoEpochForPartitionException.html
kafka/network/RequestChannel.html
kafka/producer/BrokerPartitionInfo.html
index/index-p.html
kafka/utils/immutable.html
kafka/tools/ReplayLogProducer$$Config.html
kafka/metrics/KafkaMetricsConfig.html
kafka/tools/package.html
kafka/tools/VerifyConsumerRebalance$.html
kafka/api/TopicData.html
kafka/javaapi/PartitionMetadata.html
kafka/utils/LeaderExistsOrChangedListener.html
kafka/api/PartitionMetadata.html
kafka/utils/NOT_READY$.html
kafka/tools/SimpleConsumerShell$.html
kafka/utils/Logging.html
kafka/common/MessageSizeTooLargeException.html
kafka/utils/Log4jController$.html
kafka/network/RequestChannel$$ResponseAction.html
kafka/network/RequestChannel$.html
kafka/controller/ReplicaStateMachine$BrokerChangeListener.html
lib/unselected.png
kafka/server/KafkaApis$DelayedFetch.html
kafka/server/KafkaServerStartable.html
index/index-o.html
kafka/utils/DONE$.html
kafka/api/ProducerRequest.html
kafka/network/Send.html
lib/arrow-right.png
kafka/controller/OfflineReplica$.html
lib/type_big.png
kafka/utils/READY$.html
lib/template.css
lib/signaturebg2.gif
kafka/server/HighwaterMarkCheckpoint$.html
kafka/admin/ReassignmentCompleted$.html
lib/object_to_class_big.png
kafka/producer/ProducerTopicStatsRegistry$.html
kafka/tools/KafkaMigrationTool.html
kafka/server/BrokerTopicStats$.html
kafka/server/ZookeeperLeaderElector.html
kafka/network/RequestChannel$$Request.html
kafka/tools/StateChangeLogMerger$$dateBasedOrdering$.html
kafka/admin/ReassignmentStatus.html
kafka/api/FetchRequest.html
kafka/utils/SystemTime$.html
kafka/serializer/Encoder.html
kafka/consumer/FetchRequestAndResponseStats.html
kafka/consumer/KafkaStream.html
kafka/api/ProducerResponse$.html
index/index-z.html
kafka/consumer/PartitionTopicInfo$.html
kafka/utils/ZkUtils$.html
kafka/server/KafkaRequestHandler.html
kafka/utils/Throttler$.html
kafka/common/KafkaException.html
kafka/message/MessageSet$.html
kafka/producer/PartitionAndLeader.html
kafka/log/OffsetIndex.html
kafka/admin/AdministrationException.html
kafka/server/BrokerAndFetcherId.html
kafka/server/KafkaApis.html
lib/arrow-down.png
kafka/cluster/package.html
kafka/api/ControlledShutdownResponse$.html
kafka/admin/ReassignmentInProgress$.html
lib/filterboxbg.gif
index/index-e.html
kafka/api/StopReplicaRequest.html
kafka/network/Receive.html
kafka/consumer/NoOpMessageFormatter.html
kafka/message/ByteBufferMessageSet$.html
lib/filterbg.gif
kafka/consumer/ConsumerConfig$.html
kafka/server/ZookeeperLeaderElector$LeaderChangeListener.html
kafka/producer/ProducerRequestStats.html
lib/selected-right-implicits.png
kafka/api/TopicData$.html
kafka/server/BrokerTopicMetrics.html
lib/trait_to_object_big.png
kafka/api/PartitionStateInfo$.html
kafka/server/ReplicaManager$.html
kafka/controller/LeaderIsrAndControllerEpoch.html
kafka/controller/ControllerBrokerRequestBatch.html
kafka/admin/package.html
kafka/producer/async/package.html
kafka/controller/ControllerBrokerStateInfo.html
lib/trait_diagram.png
kafka/consumer/ConsumerTimeoutException.html
lib/class_big.png
kafka/producer/async/ProducerSendThread.html
kafka/javaapi/consumer/ConsumerConnector.html
kafka/consumer/TopicFilter.html
lib/class_to_object_big.png
kafka/producer/SyncProducerConfig.html
kafka/controller/PartitionState.html
kafka/utils/KafkaScheduler.html
kafka/tools/StateChangeLogMerger$$LineIterator.html
kafka/api/PartitionMetadata$.html
kafka/controller/NonExistentPartition$.html
lib/packagesbg.gif
kafka/server/DelayedRequest.html
kafka/utils/IteratorTemplate.html
kafka/api/FetchResponse.html
kafka/controller/PartitionLeaderSelector.html
kafka/message/MessageSet.html
index/index-s.html
kafka/controller/PreferredReplicaElectionListener.html
kafka/controller/KafkaController.html
lib/class.png
kafka/common/NoReplicaOnlineException.html
kafka/api/StopReplicaResponse.html
kafka/log/Log$.html
kafka/consumer/Whitelist.html
kafka/server/FetcherStats.html
kafka/admin/PreferredReplicaLeaderElectionCommand$.html
kafka/consumer/ZookeeperTopicEventWatcher$ZkSessionExpireListener.html
kafka/network/RequestMetrics.html
kafka/api/TopicDataSend.html
kafka/common/ClientIdAndBroker.html
kafka/admin/ReassignPartitionsCommand$.html
kafka/producer/ProducerStats.html
kafka/utils/MockTime.html
lib/selected-right.png
index/index-j.html
kafka/common/TopicExistsException.html
kafka/controller/NoOpLeaderSelector.html
kafka/utils/Pool.html
kafka/consumer/ConsumerConnector.html
kafka/tools/UpdateOffsetsInZK$.html
kafka/message/MessageAndOffset.html
kafka/server/FetcherLagMetrics.html
kafka/producer/KafkaLog4jAppender.html
kafka/producer/ProducerRequestStatsRegistry$.html
kafka/server/ReplicaFetcherManager.html
lib/filter_box_left.png
kafka/server/package.html
kafka/api/FetchRequestBuilder.html
kafka/log/OffsetPosition.html
kafka/controller/ControllerChannelManager.html
kafka/controller/KafkaControllerMBean.html
kafka/network/ConnectionConfig.html
kafka/admin/ReassignmentFailed$.html
kafka/api/LeaderAndIsrResponse.html
kafka/common/FailedToSendMessageException.html
kafka/message/NoCompressionCodec$.html
kafka/controller/KafkaController$.html
kafka/producer/ProducerClosedException.html
kafka/api/PartitionFetchInfo.html
lib/diagrams.js
lib/object_big.png
kafka/controller/PartitionStateMachine$AddPartitionsListener.html
kafka/consumer/SimpleConsumer.html
index/index-u.html
kafka/api/FetchResponsePartitionData$.html
lib/ownerbg.gif
kafka/server/FetcherLagStats.html
kafka/server/KafkaApis$ProduceResult.html
package.html
kafka/api/OffsetResponse.html
kafka/tools/GetOffsetShell$.html
kafka/api/StopReplicaResponse$.html
kafka/common/QueueFullException.html
kafka/javaapi/message/package.html
kafka/javaapi/OffsetResponse.html
kafka/utils/ZKConfig.html
kafka/serializer/StringEncoder.html
kafka/producer/KeyedMessage.html
lib/object.png
kafka/controller/ControllerStats$.html
kafka/serializer/StringDecoder.html
kafka/client/ClientUtils$.html
kafka/controller/NewPartition$.html
kafka/message/CompressionFactory$.html
kafka/producer/async/IllegalQueueStateException.html
lib/signaturebg.gif
kafka/serializer/DefaultDecoder.html
kafka/api/UpdateMetadataRequest.html
kafka/api/UpdateMetadataResponse.html
kafka/cluster/Partition.html
lib/trait.png
kafka/server/KafkaApis$FetchRequestPurgatory.html
kafka/utils/Throttler.html
kafka/tools/ReplayLogProducer$$ZKConsumerThread.html
index.js
kafka/javaapi/consumer/SimpleConsumer.html
kafka/producer/ProducerPool.html
kafka/message/ByteBufferBackedInputStream.html
index/index-m.html
kafka/controller/ReassignedPartitionLeaderSelector.html
kafka/consumer/ConsumerFetcherThread.html
kafka/common/InvalidOffsetException.html
kafka/api/LeaderAndIsrRequest$.html
kafka/server/HighwaterMarkCheckpoint.html
lib/class_diagram.png
kafka/controller/RequestSendThread.html
kafka/api/PartitionDataSend.html
kafka/api/TopicMetadataRequest$.html
lib/diagrams.css
kafka/consumer/ZookeeperTopicEventWatcher$ZkTopicEventListener.html
kafka/controller/ReplicaStateMachine.html
kafka/tools/DumpLogSegments$.html
kafka/message/Message.html
kafka/api/ProducerRequest$.html
kafka/serializer/NullEncoder.html
kafka/log/FileMessageSet.html
kafka/api/ProducerResponse.html
kafka/api/TopicMetadataRequest.html
kafka/network/RequestChannel$$CloseConnectionAction$.html
lib/type_to_object_big.png
kafka/controller/PartitionAndReplica.html
kafka/metrics/KafkaMetricsGroup.html
kafka/controller/PartitionsReassignedListener.html
index/index-r.html
kafka/controller/OnlinePartition$.html
kafka/message/CompressionCodec.html
kafka/javaapi/OffsetRequest.html
index/index-l.html
kafka/server/ReplicaFetcherThread.html
kafka/controller/ReassignedPartitionsContext.html
kafka/utils/FAILED$.html
kafka/server/KafkaApis$DelayedProduce$PartitionStatus.html
kafka/api/ControlledShutdownRequest$.html
lib/selected2.png
kafka/utils/State.html
kafka/message/DefaultCompressionCodec$.html
kafka/javaapi/consumer/package.html
kafka/tools/JmxTool$.html
kafka/common/Topic$.html
kafka/network/RequestMetrics$.html
kafka/admin/PreferredReplicaLeaderElectionCommand.html
lib/conversionbg.gif
kafka/message/GZIPCompressionCodec$.html
kafka/message/MessageLengthException.html
lib/ref-index.css
kafka/common/package.html
kafka/controller/NonExistentReplica$.html
index/index-g.html
kafka/producer/ProducerConfig$.html
kafka/api/FetchResponsePartitionData.html
kafka/server/KafkaZooKeeper.html
index.html
kafka/api/TopicMetadata$.html
lib/modernizr.custom.js
kafka/javaapi/producer/package.html
kafka/producer/SyncProducer.html
kafka/server/KafkaConfig.html
kafka/controller/OfflinePartitionLeaderSelector.html
index/index-i.html
kafka/consumer/ConsumerIterator.html
kafka/common/AdminCommandFailedException.html
kafka/common/UnavailableProducerException.html
lib/type.png
kafka/server/ClientIdBrokerTopicPartition.html
kafka/utils/CommandLineUtils$.html
kafka/api/ProducerResponseStatus.html
kafka/api/ApiUtils$.html
kafka/controller/ControllerEpochListener.html
kafka/message/InvalidMessageException.html
kafka/consumer/MessageFormatter$.html
kafka/tools/ExportZkOffsets$.html
kafka/producer/ProducerRequestMetrics.html
kafka/network/RequestChannel$$NoOpAction$.html
kafka/producer/ConsoleProducer$$MessageReader.html
kafka/api/FetchResponse$.html
kafka/api/TopicMetadata.html
kafka/producer/ConsoleProducer$.html
kafka/tools/ReplayLogProducer$.html
kafka/metrics/KafkaMetricsReporter$.html
kafka/api/FetchResponseSend.html
kafka/javaapi/TopicMetadataResponse.html
kafka/api/TopicMetadataResponse$.html
kafka/api/RequestKeys$.html
index/index-d.html
lib/filter_box_left2.gif
lib/fullcommenttopbg.gif
kafka/consumer/FetchRequestAndResponseStatsRegistry$.html
kafka/tools/ImportZkOffsets$.html
kafka/serializer/package.html
kafka/admin/CreateTopicCommand$.html
kafka/consumer/ConsumerFetcherManager.html
kafka/utils/Mx4jLoader$.html
kafka/server/AbstractFetcherManager.html
kafka/common/NoBrokersForPartitionException.html
kafka/network/RequestChannel$$Response.html
index/index-f.html
kafka/server/KafkaRequestHandlerPool.html
kafka/tools/ConsumerOffsetChecker$.html
kafka/common/LeaderNotAvailableException.html
lib/template.js
lib/scheduler.js
kafka/api/UpdateMetadataResponse$.html
kafka/common/ControllerMovedException.html
kafka/server/AbstractFetcherThread.html
kafka/utils/Range.html
kafka/producer/async/MissingConfigException.html
kafka/client/package.html
kafka/javaapi/TopicMetadataRequest.html
kafka/admin/ListTopicCommand$.html
kafka/api/PartitionOffsetsResponse.html
lib/navigation-li.png
kafka/common/InvalidTopicException.html
lib/type_diagram.png
lib/object_to_trait_big.png
kafka/utils/ZKGroupTopicDirs.html
kafka/log/LogSegment.html
kafka/common/UnknownTopicOrPartitionException.html
lib/filter_box_right.png
kafka/common/RequestTimedOutException.html
index/index-v.html
kafka/producer/SyncProducerConfigShared.html
kafka/api/OffsetResponse$.html
#内容未全部加载，请点击展开加载全部代码(NowJava.com)