kafka_2.10-0.8.0-sources.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka_2.10</artifactId>
	<version>0.8.0</version>
	<classifier>sources</classifier>
	<type>java-source</type>
</dependency>

org.apache.kafka:kafka_2.10:0.8.0

META-INF/MANIFEST.MF
kafka/producer/ByteArrayPartitioner.scala
kafka/server/ReplicaFetcherManager.scala
kafka/common/NoBrokersForPartitionException.scala
kafka/javaapi/producer/Producer.scala
kafka/utils/Time.scala
kafka/common/ReplicaNotAvailableException.scala
kafka/api/FetchResponse.scala
kafka/javaapi/message/MessageSet.scala
kafka/common/BrokerNotExistException.scala
kafka/log/OffsetIndex.scala
kafka/server/KafkaApis.scala
kafka/admin/AddPartitionsCommand.scala
kafka/network/SocketServer.scala
kafka/producer/ConsoleProducer.scala
kafka/common/ControllerMovedException.scala
kafka/common/AdminCommandFailedException.scala
kafka/javaapi/OffsetRequest.scala
kafka/producer/async/DefaultEventHandler.scala
kafka/server/ReplicaFetcherThread.scala
kafka/server/KafkaServerStartable.scala
kafka/controller/KafkaController.scala
kafka/consumer/ConsoleConsumer.scala
kafka/api/LeaderAndIsrRequest.scala
kafka/cluster/Broker.scala
kafka/utils/Pool.scala
kafka/network/Handler.scala
kafka/common/KafkaZookeperClient.scala
kafka/javaapi/TopicMetadataRequest.scala
kafka/producer/Producer.scala
kafka/javaapi/consumer/ZookeeperConsumerConnector.scala
kafka/utils/Range.scala
kafka/controller/PartitionLeaderSelector.scala
kafka/javaapi/consumer/ConsumerConnector.java
kafka/utils/VerifiableProperties.scala
kafka/api/TopicMetadata.scala
kafka/consumer/TopicFilter.scala
kafka/api/OffsetRequest.scala
kafka/common/LeaderNotAvailableException.scala
kafka/common/ClientIdAndTopic.scala
kafka/common/InvalidTopicException.scala
kafka/utils/IteratorTemplate.scala
kafka/client/ClientUtils.scala
kafka/metrics/KafkaCSVMetricsReporter.scala
kafka/consumer/ConsumerTopicStat.scala
kafka/producer/DefaultPartitioner.scala
kafka/common/UnknownException.scala
kafka/message/ByteBufferBackedInputStream.scala
kafka/common/UnavailableProducerException.scala
kafka/javaapi/consumer/SimpleConsumer.scala
kafka/utils/Throttler.scala
kafka/log/LogManager.scala
kafka/utils/Topic.scala
kafka/api/RequestOrResponse.scala
kafka/controller/ControllerChannelManager.scala
kafka/producer/ProducerPool.scala
kafka/consumer/TopicCount.scala
kafka/api/UpdateMetadataResponse.scala
kafka/log/Log.scala
kafka/log/OffsetPosition.scala
kafka/common/BrokerNotAvailableException.scala
kafka/producer/async/EventHandler.scala
kafka/javaapi/Implicits.scala
kafka/api/ControlledShutdownRequest.scala
kafka/api/ControlledShutdownResponse.scala
kafka/common/TopicExistsException.scala
kafka/controller/ReplicaStateMachine.scala
kafka/tools/VerifyConsumerRebalance.scala
kafka/producer/async/IllegalQueueStateException.scala
kafka/api/LeaderAndIsrResponse.scala
kafka/utils/Os.scala
kafka/javaapi/FetchRequest.scala
kafka/server/LeaderElector.scala
kafka/api/OffsetResponse.scala
kafka/api/TopicMetadataResponse.scala
kafka/utils/MockTime.scala
kafka/cluster/Partition.scala
kafka/message/MessageLengthException.scala
kafka/api/StopReplicaRequest.scala
kafka/utils/Log4jController.scala
kafka/admin/DeleteTopicCommand.scala
kafka/admin/CreateTopicCommand.scala
kafka/tools/DumpLogSegments.scala
kafka/cluster/Cluster.scala
kafka/common/ConsumerReblanceFailedException.scala
kafka/api/UpdateMetadataRequest.scala
kafka/javaapi/message/ByteBufferMessageSet.scala
kafka/tools/SimpleConsumerShell.scala
kafka/javaapi/TopicMetadata.scala
kafka/admin/ShutdownBroker.scala
kafka/message/CompressionFactory.scala
kafka/log/FileMessageSet.scala
kafka/message/CompressionCodec.scala
kafka/server/KafkaConfig.scala
kafka/common/TopicAndPartition.scala
kafka/message/MessageAndOffset.scala
kafka/common/OffsetOutOfRangeException.scala
kafka/server/RequestPurgatory.scala
kafka/utils/Mx4jLoader.scala
kafka/network/InvalidRequestException.scala
kafka/producer/async/AsyncProducerStats.scala
kafka/admin/PreferredReplicaLeaderElectionCommand.scala
kafka/message/ByteBufferMessageSet.scala
kafka/producer/SyncProducerConfig.scala
kafka/utils/ShutdownableThread.scala
kafka/api/ApiUtils.scala
kafka/producer/BrokerPartitionInfo.scala
kafka/network/BoundedByteBufferReceive.scala
kafka/server/KafkaServer.scala
kafka/tools/ExportZkOffsets.scala
kafka/javaapi/TopicMetadataResponse.scala
kafka/server/AbstractFetcherManager.scala
kafka/producer/SyncProducer.scala
kafka/server/KafkaZooKeeper.scala
kafka/common/InvalidOffsetException.scala
kafka/producer/async/ProducerSendThread.scala
kafka/common/UnknownCodecException.scala
kafka/message/InvalidMessageException.scala
kafka/consumer/ZookeeperTopicEventWatcher.scala
kafka/utils/Annotations_2.9+.scala
kafka/tools/ConsumerOffsetChecker.scala
kafka/common/QueueFullException.scala
kafka/utils/FileLock.scala
kafka/api/ProducerRequest.scala
kafka/server/HighwaterMarkCheckpoint.scala
kafka/admin/AdminUtils.scala
kafka/tools/StateChangeLogMerger.scala
kafka/producer/ProducerTopicStats.scala
kafka/network/ByteBufferSend.scala
kafka/api/StopReplicaResponse.scala
kafka/network/BlockingChannel.scala
kafka/admin/ListTopicCommand.scala
kafka/Kafka.scala
kafka/tools/ImportZkOffsets.scala
kafka/consumer/ConsumerTopicStats.scala
kafka/common/FailedToSendMessageException.scala
kafka/network/Transmission.scala
kafka/log/SegmentList.scala
kafka/common/ErrorMapping.scala
kafka/consumer/FetchRequestAndResponseStats.scala
kafka/common/KafkaException.scala
kafka/common/NoEpochForPartitionException.scala
kafka/producer/KafkaLog4jAppender.scala
kafka/metrics/KafkaTimer.scala
kafka/consumer/TopicEventHandler.scala
kafka/common/RequestTimedOutException.scala
kafka/cluster/Replica.scala
kafka/producer/KeyedMessage.scala
kafka/metrics/KafkaMetricsReporter.scala
kafka/producer/Partitioner.scala
kafka/common/NoReplicaOnlineException.scala
kafka/common/MessageSizeTooLargeException.scala
kafka/message/MessageSet.scala
kafka/tools/MirrorMaker.scala
kafka/server/ZookeeperLeaderElector.scala
kafka/server/MessageSetSend.scala
kafka/serializer/Encoder.scala
kafka/tools/ReplayLogProducer.scala
kafka/network/BoundedByteBufferSend.scala
kafka/utils/Utils.scala
kafka/network/ConnectionConfig.scala
kafka/producer/ProducerClosedException.scala
kafka/server/KafkaRequestHandler.scala
kafka/common/Config.scala
kafka/producer/ProducerConfig.scala
kafka/tools/KafkaMigrationTool.java
kafka/consumer/ConsumerFetcherThread.scala
kafka/admin/ReassignPartitionsCommand.scala
kafka/utils/DelayedItem.scala
kafka/common/StateChangeFailedException.scala
kafka/common/KafkaStorageException.scala
kafka/utils/ZkUtils.scala
kafka/tools/GetOffsetShell.scala
kafka/serializer/Decoder.scala
#内容未全部加载，请点击展开加载全部代码(NowJava.com)