首页
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-sources.jar
标签:kafka_2.11-0.8.2-beta-sources.jar,kafka_2.11,0.8.2,beta,sources,jar包下载,依赖包
  • 云盘下载
  • Group
  • Artifact
  • Version
  • Download
  • >> Package Explorer
  • >>> Java Explorer <2.6.8>
    • kafka
      • admin
        • AdminOperationException.scala
        • AdminUtils.scala
        • PreferredReplicaLeaderElectionCommand.scala
        • ReassignPartitionsCommand.scala
        • TopicCommand.scala
      • api
        • ApiUtils.scala
        • ConsumerMetadataRequest.scala
        • ConsumerMetadataResponse.scala
        • ControlledShutdownRequest.scala
        • ControlledShutdownResponse.scala
        • FetchRequest.scala
        • FetchResponse.scala
        • GenericRequestAndHeader.scala
        • GenericResponseAndHeader.scala
        • HeartbeatRequestAndHeader.scala
        • HeartbeatResponseAndHeader.scala
        • JoinGroupRequestAndHeader.scala
        • JoinGroupResponseAndHeader.scala
        • LeaderAndIsrRequest.scala
        • LeaderAndIsrResponse.scala
        • OffsetCommitRequest.scala
        • OffsetCommitResponse.scala
        • OffsetFetchRequest.scala
        • OffsetFetchResponse.scala
        • OffsetRequest.scala
        • OffsetResponse.scala
        • ProducerRequest.scala
        • ProducerResponse.scala
        • RequestKeys.scala
        • RequestOrResponse.scala
        • StopReplicaRequest.scala
        • StopReplicaResponse.scala
        • TopicMetadata.scala
        • TopicMetadataRequest.scala
        • TopicMetadataResponse.scala
        • UpdateMetadataRequest.scala
        • UpdateMetadataResponse.scala
      • client
        • ClientUtils.scala
      • cluster
        • Broker.scala
        • Cluster.scala
        • Partition.scala
        • Replica.scala
      • common
        • AdminCommandFailedException.scala
        • BrokerNotAvailableException.scala
        • ClientIdAndBroker.scala
        • ClientIdAndTopic.scala
        • Config.scala
        • ConsumerCoordinatorNotAvailableException.scala
        • ConsumerReblanceFailedException.scala
        • ControllerMovedException.scala
        • ErrorMapping.scala
        • FailedToSendMessageException.scala
        • InvalidConfigException.scala
        • InvalidMessageSizeException.scala
        • InvalidOffsetException.scala
        • InvalidTopicException.scala
        • KafkaException.scala
        • KafkaStorageException.scala
        • LeaderElectionNotNeededException.scala
        • LeaderNotAvailableException.scala
        • LogCleaningAbortedException.scala
        • MessageSetSizeTooLargeException.scala
        • MessageSizeTooLargeException.scala
        • MessageStreamsExistException.scala
        • NoBrokersForPartitionException.scala
        • NoEpochForPartitionException.scala
        • NoReplicaOnlineException.scala
        • NotAssignedReplicaException.scala
        • NotCoordinatorForConsumerException.scala
        • NotEnoughReplicasAfterAppendException.scala
        • NotEnoughReplicasException.scala
        • NotLeaderForPartitionException.scala
        • OffsetMetadataAndError.scala
        • OffsetMetadataTooLargeException.scala
        • OffsetOutOfRangeException.scala
        • OffsetsLoadInProgressException.scala
        • QueueFullException.scala
        • ReplicaNotAvailableException.scala
        • RequestTimedOutException.scala
        • StateChangeFailedException.scala
        • ThreadShutdownException.scala
        • Topic.scala
        • TopicAndPartition.scala
        • TopicExistsException.scala
        • UnavailableProducerException.scala
        • UnknownCodecException.scala
        • UnknownException.scala
        • UnknownMagicByteException.scala
        • UnknownTopicOrPartitionException.scala
      • consumer
        • ConsumerConfig.scala
        • ConsumerConnector.scala
        • ConsumerFetcherManager.scala
        • ConsumerFetcherThread.scala
        • ConsumerIterator.scala
        • ConsumerTopicStats.scala
        • FetchedDataChunk.scala
        • FetchRequestAndResponseStats.scala
        • KafkaStream.scala
        • PartitionAssignor.scala
        • PartitionTopicInfo.scala
        • SimpleConsumer.scala
        • TopicCount.scala
        • TopicEventHandler.scala
        • TopicFilter.scala
        • ZookeeperConsumerConnector.scala
        • ZookeeperTopicEventWatcher.scala
      • controller
        • ControllerChannelManager.scala
        • KafkaController.scala
        • PartitionLeaderSelector.scala
        • PartitionStateMachine.scala
        • ReplicaStateMachine.scala
        • TopicDeletionManager.scala
      • javaapi
        • consumer
          • ConsumerConnector.java
          • SimpleConsumer.scala
          • ZookeeperConsumerConnector.scala
        • ConsumerMetadataResponse.scala
        • FetchRequest.scala
        • FetchResponse.scala
        • Implicits.scala
        • message
          • ByteBufferMessageSet.scala
          • MessageSet.scala
        • OffsetCommitRequest.scala
        • OffsetCommitResponse.scala
        • OffsetFetchRequest.scala
        • OffsetFetchResponse.scala
        • OffsetRequest.scala
        • OffsetResponse.scala
        • producer
          • Producer.scala
        • TopicMetadata.scala
        • TopicMetadataRequest.scala
        • TopicMetadataResponse.scala
      • Kafka.scala
      • log
        • CleanerConfig.scala
        • FileMessageSet.scala
        • Log.scala
        • LogCleaner.scala
        • LogCleanerManager.scala
        • LogConfig.scala
        • LogManager.scala
        • LogSegment.scala
        • OffsetIndex.scala
        • OffsetMap.scala
        • OffsetPosition.scala
      • message
        • ByteBufferBackedInputStream.scala
        • ByteBufferMessageSet.scala
        • CompressionCodec.scala
        • CompressionFactory.scala
        • InvalidMessageException.scala
        • Message.scala
        • MessageAndMetadata.scala
        • MessageAndOffset.scala
        • MessageLengthException.scala
        • MessageSet.scala
      • metrics
        • KafkaCSVMetricsReporter.scala
        • KafkaMetricsConfig.scala
        • KafkaMetricsGroup.scala
        • KafkaMetricsReporter.scala
        • KafkaTimer.scala
      • network
        • BlockingChannel.scala
        • BoundedByteBufferReceive.scala
        • BoundedByteBufferSend.scala
        • ByteBufferSend.scala
        • ConnectionConfig.scala
        • Handler.scala
        • InvalidRequestException.scala
        • RequestChannel.scala
        • SocketServer.scala
        • Transmission.scala
      • producer
        • async
          • AsyncProducerConfig.scala
          • DefaultEventHandler.scala
          • EventHandler.scala
          • IllegalQueueStateException.scala
          • MissingConfigException.scala
          • ProducerSendThread.scala
        • BaseProducer.scala
        • BrokerPartitionInfo.scala
        • ByteArrayPartitioner.scala
        • DefaultPartitioner.scala
        • KafkaLog4jAppender.scala
        • KeyedMessage.scala
        • Partitioner.scala
        • Producer.scala
        • ProducerClosedException.scala
        • ProducerConfig.scala
        • ProducerPool.scala
        • ProducerRequestStats.scala
        • ProducerStats.scala
        • ProducerTopicStats.scala
        • SyncProducer.scala
        • SyncProducerConfig.scala
      • serializer
        • Decoder.scala
        • Encoder.scala
      • server
        • AbstractFetcherManager.scala
        • AbstractFetcherThread.scala
        • BrokerStates.scala
        • DelayedFetch.scala
        • DelayedProduce.scala
        • DelayedRequestKey.scala
        • FetchDataInfo.scala
        • FetchRequestPurgatory.scala
        • KafkaApis.scala
        • KafkaConfig.scala
        • KafkaHealthcheck.scala
        • KafkaRequestHandler.scala
        • KafkaServer.scala
        • KafkaServerStartable.scala
        • LeaderElector.scala
        • LogOffsetMetadata.scala
        • MessageSetSend.scala
        • MetadataCache.scala
        • OffsetCheckpoint.scala
        • OffsetManager.scala
        • ProducerRequestPurgatory.scala
        • ReplicaFetcherManager.scala
        • ReplicaFetcherThread.scala
        • ReplicaManager.scala
        • RequestPurgatory.scala
        • TopicConfigManager.scala
        • ZookeeperLeaderElector.scala
      • tools
        • ConsoleConsumer.scala
        • ConsoleProducer.scala
        • ConsumerOffsetChecker.scala
        • ConsumerPerformance.scala
        • DumpLogSegments.scala
        • ExportZkOffsets.scala
        • GetOffsetShell.scala
        • ImportZkOffsets.scala
        • JmxTool.scala
        • KafkaMigrationTool.java
        • MirrorMaker.scala
        • PerfConfig.scala
        • ProducerPerformance.scala
        • ReplayLogProducer.scala
        • ReplicaVerificationTool.scala
        • SimpleConsumerPerformance.scala
        • SimpleConsumerShell.scala
        • StateChangeLogMerger.scala
        • TestEndToEndLatency.scala
        • TestLogCleaning.scala
        • UpdateOffsetsInZK.scala
        • VerifyConsumerRebalance.scala
        • ZooKeeperMainWrapper.scala
      • utils
        • Annotations.scala
        • CommandLineUtils.scala
        • Crc32.java
        • DelayedItem.scala
        • FileLock.scala
        • IteratorTemplate.scala
        • Json.scala
        • KafkaScheduler.scala
        • Log4jController.scala
        • Logging.scala
        • Mx4jLoader.scala
        • Os.scala
        • Pool.scala
        • ReplicationUtils.scala
        • ShutdownableThread.scala
        • Throttler.scala
        • Time.scala
        • ToolsUtils.scala
        • Utils.scala
        • VerifiableProperties.scala
        • ZkUtils.scala
    • LICENSE
    • META-INF
      • MANIFEST.MF
    • NOTICE