首页
A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
Q
R
S
T
U
V
W
X
Y
Z
> kafka_2.11-0.8.2-beta-scaladoc.jar
标签:kafka_2.11-0.8.2-beta-scaladoc.jar,kafka_2.11,0.8.2,beta,scaladoc,jar包下载,依赖包
  • 云盘下载
  • Group
  • Artifact
  • Version
  • Download
  • >> Package Explorer
  • >>> Java Explorer <2.6.8>
    • index
      • index-a.html
      • index-b.html
      • index-c.html
      • index-d.html
      • index-e.html
      • index-f.html
      • index-g.html
      • index-h.html
      • index-i.html
      • index-j.html
      • index-k.html
      • index-l.html
      • index-m.html
      • index-n.html
      • index-o.html
      • index-p.html
      • index-q.html
      • index-r.html
      • index-s.html
      • index-t.html
      • index-u.html
      • index-v.html
      • index-w.html
      • index-z.html
    • index.html
    • index.js
    • kafka
      • admin
        • AdminOperationException.html
        • AdminUtils$.html
        • package.html
        • PreferredReplicaLeaderElectionCommand$.html
        • PreferredReplicaLeaderElectionCommand.html
        • ReassignmentCompleted$.html
        • ReassignmentFailed$.html
        • ReassignmentInProgress$.html
        • ReassignmentStatus.html
        • ReassignPartitionsCommand$$ReassignPartitionsCommandOptions.html
        • ReassignPartitionsCommand$.html
        • ReassignPartitionsCommand.html
        • TopicCommand$$TopicCommandOptions.html
        • TopicCommand$.html
      • api
        • ApiUtils$.html
        • ConsumerMetadataRequest$.html
        • ConsumerMetadataRequest.html
        • ConsumerMetadataResponse$.html
        • ConsumerMetadataResponse.html
        • ControlledShutdownRequest$.html
        • ControlledShutdownRequest.html
        • ControlledShutdownResponse$.html
        • ControlledShutdownResponse.html
        • FetchRequest$.html
        • FetchRequest.html
        • FetchRequestBuilder.html
        • FetchResponse$.html
        • FetchResponse.html
        • FetchResponsePartitionData$.html
        • FetchResponsePartitionData.html
        • FetchResponseSend.html
        • HeartbeatRequestAndHeader$.html
        • HeartbeatRequestAndHeader.html
        • HeartbeatResponseAndHeader$.html
        • HeartbeatResponseAndHeader.html
        • JoinGroupRequestAndHeader$.html
        • JoinGroupRequestAndHeader.html
        • JoinGroupResponseAndHeader$.html
        • JoinGroupResponseAndHeader.html
        • LeaderAndIsr$.html
        • LeaderAndIsr.html
        • LeaderAndIsrRequest$.html
        • LeaderAndIsrRequest.html
        • LeaderAndIsrResponse$.html
        • LeaderAndIsrResponse.html
        • OffsetCommitRequest$.html
        • OffsetCommitRequest.html
        • OffsetCommitResponse$.html
        • OffsetCommitResponse.html
        • OffsetFetchRequest$.html
        • OffsetFetchRequest.html
        • OffsetFetchResponse$.html
        • OffsetFetchResponse.html
        • OffsetRequest$.html
        • OffsetRequest.html
        • OffsetResponse$.html
        • OffsetResponse.html
        • package.html
        • PartitionDataSend.html
        • PartitionFetchInfo.html
        • PartitionMetadata$.html
        • PartitionMetadata.html
        • PartitionOffsetRequestInfo.html
        • PartitionOffsetsResponse.html
        • PartitionStateInfo$.html
        • PartitionStateInfo.html
        • ProducerRequest$.html
        • ProducerRequest.html
        • ProducerResponse$.html
        • ProducerResponse.html
        • ProducerResponseStatus.html
        • Request$.html
        • RequestKeys$.html
        • RequestOrResponse.html
        • StopReplicaRequest$.html
        • StopReplicaRequest.html
        • StopReplicaResponse$.html
        • StopReplicaResponse.html
        • TopicData$.html
        • TopicData.html
        • TopicDataSend.html
        • TopicMetadata$.html
        • TopicMetadata.html
        • TopicMetadataRequest$.html
        • TopicMetadataRequest.html
        • TopicMetadataResponse$.html
        • TopicMetadataResponse.html
        • UpdateMetadataRequest$.html
        • UpdateMetadataRequest.html
        • UpdateMetadataResponse$.html
        • UpdateMetadataResponse.html
      • client
        • ClientUtils$.html
        • package.html
      • cluster
        • Broker$.html
        • Broker.html
        • package.html
        • Partition.html
        • Replica.html
      • common
        • AdminCommandFailedException.html
        • BrokerNotAvailableException.html
        • ClientIdAndBroker.html
        • ClientIdAndTopic.html
        • Config.html
        • ConsumerCoordinatorNotAvailableException.html
        • ConsumerRebalanceFailedException.html
        • ControllerMovedException.html
        • ErrorMapping$.html
        • FailedToSendMessageException.html
        • InvalidConfigException.html
        • InvalidMessageSizeException.html
        • InvalidOffsetException.html
        • InvalidTopicException.html
        • KafkaException.html
        • KafkaStorageException.html
        • LeaderElectionNotNeededException.html
        • LeaderNotAvailableException.html
        • LogCleaningAbortedException.html
        • MessageSetSizeTooLargeException.html
        • MessageSizeTooLargeException.html
        • MessageStreamsExistException.html
        • NoBrokersForPartitionException.html
        • NoEpochForPartitionException.html
        • NoReplicaOnlineException.html
        • NotAssignedReplicaException.html
        • NotCoordinatorForConsumerException.html
        • NotEnoughReplicasAfterAppendException.html
        • NotEnoughReplicasException.html
        • NotLeaderForPartitionException.html
        • OffsetAndMetadata$.html
        • OffsetAndMetadata.html
        • OffsetMetadataAndError$.html
        • OffsetMetadataAndError.html
        • OffsetMetadataTooLargeException.html
        • OffsetOutOfRangeException.html
        • OffsetsLoadInProgressException.html
        • package.html
        • QueueFullException.html
        • ReplicaNotAvailableException.html
        • RequestTimedOutException.html
        • StateChangeFailedException.html
        • ThreadShutdownException.html
        • Topic$.html
        • TopicAndPartition.html
        • TopicExistsException.html
        • UnavailableProducerException.html
        • UnknownCodecException.html
        • UnknownException.html
        • UnknownMagicByteException.html
        • UnknownTopicOrPartitionException.html
      • consumer
        • AssignmentContext.html
        • Blacklist.html
        • Consumer$.html
        • ConsumerConfig$.html
        • ConsumerConfig.html
        • ConsumerConnector.html
        • ConsumerFetcherManager.html
        • ConsumerFetcherThread.html
        • ConsumerIterator.html
        • ConsumerThreadId.html
        • ConsumerTimeoutException.html
        • ConsumerTopicMetrics.html
        • ConsumerTopicStats.html
        • ConsumerTopicStatsRegistry$.html
        • FetchedDataChunk.html
        • FetchRequestAndResponseMetrics.html
        • FetchRequestAndResponseStats.html
        • FetchRequestAndResponseStatsRegistry$.html
        • KafkaStream.html
        • package.html
        • PartitionAssignor$.html
        • PartitionAssignor.html
        • PartitionTopicInfo$.html
        • PartitionTopicInfo.html
        • RangeAssignor.html
        • RoundRobinAssignor.html
        • SimpleConsumer.html
        • TopicEventHandler.html
        • TopicFilter.html
        • Whitelist.html
        • ZookeeperTopicEventWatcher$ZkSessionExpireListener.html
        • ZookeeperTopicEventWatcher$ZkTopicEventListener.html
        • ZookeeperTopicEventWatcher.html
      • controller
        • Callbacks$$CallbackBuilder.html
        • Callbacks$.html
        • Callbacks.html
        • ControlledShutdownLeaderSelector.html
        • ControllerBrokerRequestBatch.html
        • ControllerBrokerStateInfo.html
        • ControllerChannelManager.html
        • ControllerContext.html
        • ControllerStats$.html
        • KafkaController$$StateChangeLogger.html
        • KafkaController$.html
        • KafkaController$SessionExpirationListener.html
        • KafkaController.html
        • LeaderIsrAndControllerEpoch.html
        • NewPartition$.html
        • NewReplica$.html
        • NonExistentPartition$.html
        • NonExistentReplica$.html
        • NoOpLeaderSelector.html
        • OfflinePartition$.html
        • OfflinePartitionLeaderSelector.html
        • OfflineReplica$.html
        • OnlinePartition$.html
        • OnlineReplica$.html
        • package.html
        • PartitionAndReplica.html
        • PartitionLeaderSelector.html
        • PartitionsReassignedListener.html
        • PartitionState.html
        • PartitionStateMachine$AddPartitionsListener.html
        • PartitionStateMachine$DeleteTopicsListener.html
        • PartitionStateMachine$TopicChangeListener.html
        • PartitionStateMachine.html
        • PreferredReplicaElectionListener.html
        • PreferredReplicaPartitionLeaderSelector.html
        • ReassignedPartitionLeaderSelector.html
        • ReassignedPartitionsContext.html
        • ReassignedPartitionsIsrChangeListener.html
        • ReplicaDeletionIneligible$.html
        • ReplicaDeletionStarted$.html
        • ReplicaDeletionSuccessful$.html
        • ReplicaState.html
        • ReplicaStateMachine$BrokerChangeListener.html
        • ReplicaStateMachine.html
        • RequestSendThread.html
        • StopReplicaRequestInfo.html
        • TopicDeletionManager$DeleteTopicsThread.html
        • TopicDeletionManager.html
      • javaapi
        • consumer
          • ConsumerConnector.html
          • package.html
          • SimpleConsumer.html
        • ConsumerMetadataResponse.html
        • FetchRequest.html
        • FetchResponse.html
        • message
          • ByteBufferMessageSet.html
          • MessageSet.html
          • package.html
        • OffsetCommitRequest.html
        • OffsetCommitResponse.html
        • OffsetFetchRequest.html
        • OffsetFetchResponse.html
        • OffsetRequest.html
        • OffsetResponse.html
        • package.html
        • PartitionMetadata.html
        • producer
          • package.html
          • Producer.html
        • TopicMetadata.html
        • TopicMetadataRequest.html
        • TopicMetadataResponse.html
      • Kafka$.html
      • log
        • CleanerConfig.html
        • Defaults$.html
        • FileMessageSet.html
        • Log$.html
        • Log$LogAppendInfo.html
        • Log.html
        • LogCleaner.html
        • LogConfig$.html
        • LogConfig.html
        • LogFlushStats$.html
        • LogManager.html
        • LogSegment.html
        • OffsetIndex.html
        • OffsetMap.html
        • OffsetPosition.html
        • package.html
        • SkimpyOffsetMap.html
      • message
        • ByteBufferBackedInputStream.html
        • ByteBufferMessageSet$.html
        • ByteBufferMessageSet.html
        • CompressionCodec$.html
        • CompressionCodec.html
        • CompressionFactory$.html
        • DefaultCompressionCodec$.html
        • GZIPCompressionCodec$.html
        • InvalidMessageException.html
        • LZ4CompressionCodec$.html
        • Message$.html
        • Message.html
        • MessageAndMetadata.html
        • MessageAndOffset.html
        • MessageLengthException.html
        • MessageSet$.html
        • MessageSet.html
        • NoCompressionCodec$.html
        • package.html
        • SnappyCompressionCodec$.html
      • metrics
        • KafkaMetricsConfig.html
        • KafkaMetricsGroup$.html
        • KafkaMetricsGroup.html
        • KafkaMetricsReporter$.html
        • KafkaMetricsReporter.html
        • KafkaMetricsReporterMBean.html
        • KafkaTimer.html
        • package.html
      • network
        • BlockingChannel$.html
        • BlockingChannel.html
        • ConnectionConfig.html
        • ConnectionQuotas.html
        • InvalidRequestException.html
        • MultiSend.html
        • package.html
        • Receive.html
        • RequestChannel$$CloseConnectionAction$.html
        • RequestChannel$$NoOpAction$.html
        • RequestChannel$$Request.html
        • RequestChannel$$Response.html
        • RequestChannel$$ResponseAction.html
        • RequestChannel$$SendAction$.html
        • RequestChannel$.html
        • RequestChannel.html
        • RequestMetrics$.html
        • RequestMetrics.html
        • Send.html
        • SocketServer.html
        • TooManyConnectionsException.html
      • package.html
      • producer
        • async
          • AsyncProducerConfig.html
          • DefaultEventHandler.html
          • EventHandler.html
          • IllegalQueueStateException.html
          • MissingConfigException.html
          • package.html
          • ProducerSendThread.html
        • BaseProducer.html
        • BrokerPartitionInfo.html
        • ByteArrayPartitioner.html
        • DefaultPartitioner.html
        • KafkaLog4jAppender.html
        • KeyedMessage.html
        • NewShinyProducer.html
        • OldProducer.html
        • package.html
        • PartitionAndLeader.html
        • Partitioner.html
        • Producer.html
        • ProducerClosedException.html
        • ProducerConfig$.html
        • ProducerConfig.html
        • ProducerPool$.html
        • ProducerPool.html
        • ProducerRequestMetrics.html
        • ProducerRequestStats.html
        • ProducerRequestStatsRegistry$.html
        • ProducerStats.html
        • ProducerStatsRegistry$.html
        • ProducerTopicMetrics.html
        • ProducerTopicStats.html
        • ProducerTopicStatsRegistry$.html
        • SyncProducer$.html
        • SyncProducer.html
        • SyncProducerConfig$.html
        • SyncProducerConfig.html
        • SyncProducerConfigShared.html
      • serializer
        • Decoder.html
        • DefaultDecoder.html
        • DefaultEncoder.html
        • Encoder.html
        • NullEncoder.html
        • package.html
        • StringDecoder.html
        • StringEncoder.html
      • server
        • AbstractFetcherManager.html
        • AbstractFetcherThread.html
        • BrokerAndFetcherId.html
        • BrokerAndInitialOffset.html
        • BrokerShuttingDown$.html
        • BrokerState.html
        • BrokerStates.html
        • BrokerTopicMetrics.html
        • BrokerTopicStats$.html
        • ClientIdBrokerTopicPartition.html
        • DelayedFetch.html
        • DelayedProduce.html
        • DelayedProduceResponseStatus.html
        • DelayedRequest.html
        • DelayedRequestKey$.html
        • DelayedRequestKey.html
        • FetchDataInfo.html
        • FetcherLagMetrics.html
        • FetcherLagStats.html
        • FetcherStats.html
        • FetchRequestPurgatory.html
        • GroupTopicPartition.html
        • KafkaApis$ProduceResult.html
        • KafkaApis.html
        • KafkaConfig.html
        • KafkaHealthcheck$SessionExpireListener.html
        • KafkaHealthcheck.html
        • KafkaRequestHandler.html
        • KafkaRequestHandlerPool.html
        • KafkaServer.html
        • KafkaServerStartable.html
        • LeaderElector.html
        • LogOffsetMetadata$$OffsetOrdering.html
        • LogOffsetMetadata$.html
        • LogOffsetMetadata.html
        • NotRunning$.html
        • OffsetCheckpoint.html
        • OffsetManager$$OffsetsMessageFormatter.html
        • OffsetManager$.html
        • OffsetManager.html
        • OffsetManagerConfig$.html
        • OffsetManagerConfig.html
        • package.html
        • PartitionDataAndOffset.html
        • PendingControlledShutdown$.html
        • ProducerRequestPurgatory.html
        • RecoveringFromUncleanShutdown$.html
        • ReplicaFetcherManager.html
        • ReplicaFetcherThread.html
        • ReplicaManager$.html
        • ReplicaManager.html
        • RequestPurgatory.html
        • RunningAsBroker$.html
        • RunningAsController$.html
        • Starting$.html
        • TopicConfigManager$ConfigChangeListener$.html
        • TopicConfigManager.html
        • TopicPartitionRequestKey.html
        • ZookeeperLeaderElector$LeaderChangeListener.html
        • ZookeeperLeaderElector.html
      • tools
        • ChecksumMessageFormatter.html
        • ConsoleConsumer$.html
        • ConsoleProducer$$LineMessageReader.html
        • ConsoleProducer$$MessageReader.html
        • ConsoleProducer$$ProducerConfig.html
        • ConsoleProducer$.html
        • ConsumerOffsetChecker$.html
        • ConsumerPerformance$$ConsumerPerfConfig.html
        • ConsumerPerformance$$ConsumerPerfThread.html
        • ConsumerPerformance$.html
        • DefaultMessageFormatter.html
        • DumpLogSegments$.html
        • ExportZkOffsets$.html
        • GetOffsetShell$.html
        • ImportZkOffsets$.html
        • JmxTool$.html
        • KafkaMigrationTool$.html
        • KafkaMigrationTool.html
        • MessageFormatter.html
        • MirrorMaker$$ConsumerThread.html
        • MirrorMaker$$DataChannel.html
        • MirrorMaker$$ProducerThread.html
        • MirrorMaker$.html
        • NoOpMessageFormatter.html
        • package.html
        • PerfConfig.html
        • ProducerPerformance$$ProducerPerfConfig.html
        • ProducerPerformance$$ProducerThread.html
        • ProducerPerformance$.html
        • ReplayLogProducer$$Config.html
        • ReplayLogProducer$$ZKConsumerThread.html
        • ReplayLogProducer$.html
        • ReplicaVerificationTool$.html
        • SimpleConsumerPerformance$$ConsumerPerfConfig.html
        • SimpleConsumerPerformance$.html
        • SimpleConsumerShell$.html
        • StateChangeLogMerger$$dateBasedOrdering$.html
        • StateChangeLogMerger$$LineIterator.html
        • StateChangeLogMerger$.html
        • TestEndToEndLatency$.html
        • TestLogCleaning$.html
        • TestRecord.html
        • UpdateOffsetsInZK$.html
        • VerifyConsumerRebalance$.html
        • ZooKeeperMainWrapper$.html
        • ZooKeeperMainWrapper.html
      • utils
        • CommandLineUtils$.html
        • Crc32.html
        • DelayedItem.html
        • DONE$.html
        • FAILED$.html
        • FileLock.html
        • immutable.html
        • IteratorTemplate.html
        • Json$.html
        • KafkaScheduler.html
        • Log4jController$.html
        • Logging.html
        • Mx4jLoader$.html
        • nonthreadsafe.html
        • NOT_READY$.html
        • Os$.html
        • package.html
        • Pool.html
        • READY$.html
        • ReplicationUtils$.html
        • Scheduler.html
        • ShutdownableThread.html
        • State.html
        • SystemTime$.html
        • threadsafe.html
        • Throttler$.html
        • Throttler.html
        • Time$.html
        • Time.html
        • ToolsUtils$.html
        • Utils$.html
        • VerifiableProperties.html
        • ZKConfig.html
        • ZKGroupDirs.html
        • ZKGroupTopicDirs.html
        • ZKStringSerializer$.html
        • ZkUtils$.html
    • lib
      • arrow-down.png
      • arrow-right.png
      • class.png
      • class_big.png
      • class_diagram.png
      • class_to_object_big.png
      • constructorsbg.gif
      • conversionbg.gif
      • defbg-blue.gif
      • defbg-green.gif
      • diagrams.css
      • diagrams.js
      • filterbg.gif
      • filterboxbarbg.gif
      • filterboxbarbg.png
      • filterboxbg.gif
      • filter_box_left.png
      • filter_box_left2.gif
      • filter_box_right.png
      • fullcommenttopbg.gif
      • index.css
      • index.js
      • jquery-ui.js
      • jquery.js
      • jquery.layout.js
      • modernizr.custom.js
      • navigation-li-a.png
      • navigation-li.png
      • object.png
      • object_big.png
      • object_diagram.png
      • object_to_class_big.png
      • object_to_trait_big.png
      • object_to_type_big.png
      • ownderbg2.gif
      • ownerbg.gif
      • ownerbg2.gif
      • package.png
      • packagesbg.gif
      • package_big.png
      • permalink.png
      • ref-index.css
      • remove.png
      • rootdoc.txt
      • scheduler.js
      • selected-implicits.png
      • selected-right-implicits.png
      • selected-right.png
      • selected.png
      • selected2-right.png
      • selected2.png
      • signaturebg.gif
      • signaturebg2.gif
      • template.css
      • template.js
      • tools.tooltip.js
      • trait.png
      • trait_big.png
      • trait_diagram.png
      • trait_to_object_big.png
      • type.png
      • typebg.gif
      • type_big.png
      • type_diagram.png
      • type_to_object_big.png
      • unselected.png
      • valuemembersbg.gif
    • LICENSE
    • META-INF
      • MANIFEST.MF
    • NOTICE
    • package.html