kafka-clients-0.8.2.2-sources.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka-clients</artifactId>
	<version>0.8.2.2</version>
	<classifier>sources</classifier>
	<type>java-source</type>
</dependency>

org.apache.kafka:kafka-clients:0.8.2.2

META-INF/MANIFEST.MF
LICENSE
NOTICE
org/apache/kafka/clients/ClientRequest.java
org/apache/kafka/clients/ClientResponse.java
org/apache/kafka/clients/ClusterConnectionStates.java
org/apache/kafka/clients/ConnectionState.java
org/apache/kafka/clients/InFlightRequests.java
org/apache/kafka/clients/KafkaClient.java
org/apache/kafka/clients/NetworkClient.java
org/apache/kafka/clients/NodeConnectionState.java
org/apache/kafka/clients/consumer/Consumer.java
org/apache/kafka/clients/consumer/ConsumerConfig.java
org/apache/kafka/clients/consumer/ConsumerRebalanceCallback.java
org/apache/kafka/clients/consumer/ConsumerRecord.java
org/apache/kafka/clients/consumer/ConsumerRecords.java
org/apache/kafka/clients/consumer/KafkaConsumer.java
org/apache/kafka/clients/consumer/MockConsumer.java
org/apache/kafka/clients/consumer/OffsetMetadata.java
org/apache/kafka/clients/producer/BufferExhaustedException.java
org/apache/kafka/clients/producer/Callback.java
org/apache/kafka/clients/producer/KafkaProducer.java
org/apache/kafka/clients/producer/MockProducer.java
org/apache/kafka/clients/producer/Producer.java
org/apache/kafka/clients/producer/ProducerConfig.java
org/apache/kafka/clients/producer/ProducerRecord.java
org/apache/kafka/clients/producer/RecordMetadata.java
org/apache/kafka/clients/producer/internals/BufferPool.java
org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java
org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java
org/apache/kafka/clients/producer/internals/Metadata.java
org/apache/kafka/clients/producer/internals/Partitioner.java
org/apache/kafka/clients/producer/internals/ProduceRequestResult.java
org/apache/kafka/clients/producer/internals/RecordAccumulator.java
org/apache/kafka/clients/producer/internals/RecordBatch.java
org/apache/kafka/clients/producer/internals/Sender.java
org/apache/kafka/clients/tools/ProducerPerformance.java
org/apache/kafka/common/Cluster.java
org/apache/kafka/common/Configurable.java
org/apache/kafka/common/KafkaException.java
org/apache/kafka/common/Metric.java
org/apache/kafka/common/MetricName.java
org/apache/kafka/common/Node.java
org/apache/kafka/common/PartitionInfo.java
org/apache/kafka/common/TopicPartition.java
org/apache/kafka/common/config/AbstractConfig.java
org/apache/kafka/common/config/ConfigDef.java
org/apache/kafka/common/config/ConfigException.java
org/apache/kafka/common/errors/ApiException.java
org/apache/kafka/common/errors/CorruptRecordException.java
org/apache/kafka/common/errors/InvalidMetadataException.java
org/apache/kafka/common/errors/InvalidTopicException.java
org/apache/kafka/common/errors/LeaderNotAvailableException.java
org/apache/kafka/common/errors/NetworkException.java
org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java
org/apache/kafka/common/errors/NotEnoughReplicasException.java
org/apache/kafka/common/errors/NotLeaderForPartitionException.java
org/apache/kafka/common/errors/OffsetMetadataTooLarge.java
org/apache/kafka/common/errors/OffsetOutOfRangeException.java
org/apache/kafka/common/errors/RecordBatchTooLargeException.java
org/apache/kafka/common/errors/RecordTooLargeException.java
org/apache/kafka/common/errors/RetriableException.java
org/apache/kafka/common/errors/SerializationException.java
org/apache/kafka/common/errors/TimeoutException.java
org/apache/kafka/common/errors/UnknownServerException.java
org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java
org/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
org/apache/kafka/common/message/KafkaLZ4BlockOutputStream.java
org/apache/kafka/common/metrics/CompoundStat.java
org/apache/kafka/common/metrics/JmxReporter.java
org/apache/kafka/common/metrics/KafkaMetric.java
org/apache/kafka/common/metrics/Measurable.java
org/apache/kafka/common/metrics/MeasurableStat.java
org/apache/kafka/common/metrics/MetricConfig.java
org/apache/kafka/common/metrics/Metrics.java
org/apache/kafka/common/metrics/MetricsReporter.java
org/apache/kafka/common/metrics/Quota.java
org/apache/kafka/common/metrics/QuotaViolationException.java
org/apache/kafka/common/metrics/Sensor.java
org/apache/kafka/common/metrics/Stat.java
org/apache/kafka/common/metrics/stats/Avg.java
org/apache/kafka/common/metrics/stats/Count.java
org/apache/kafka/common/metrics/stats/Histogram.java
org/apache/kafka/common/metrics/stats/Max.java
org/apache/kafka/common/metrics/stats/Min.java
org/apache/kafka/common/metrics/stats/Percentile.java
org/apache/kafka/common/metrics/stats/Percentiles.java
org/apache/kafka/common/metrics/stats/Rate.java
org/apache/kafka/common/metrics/stats/SampledStat.java
org/apache/kafka/common/metrics/stats/Total.java
org/apache/kafka/common/network/ByteBufferReceive.java
org/apache/kafka/common/network/ByteBufferSend.java
org/apache/kafka/common/network/NetworkReceive.java
org/apache/kafka/common/network/NetworkSend.java
org/apache/kafka/common/network/Receive.java
org/apache/kafka/common/network/Selectable.java
org/apache/kafka/common/network/Selector.java
org/apache/kafka/common/network/Send.java
org/apache/kafka/common/protocol/ApiKeys.java
org/apache/kafka/common/protocol/Errors.java
org/apache/kafka/common/protocol/Protocol.java
org/apache/kafka/common/protocol/ProtoUtils.java
org/apache/kafka/common/protocol/types/ArrayOf.java
org/apache/kafka/common/protocol/types/Field.java
org/apache/kafka/common/protocol/types/Schema.java
org/apache/kafka/common/protocol/types/SchemaException.java
org/apache/kafka/common/protocol/types/Struct.java
org/apache/kafka/common/protocol/types/Type.java
org/apache/kafka/common/record/ByteBufferInputStream.java
org/apache/kafka/common/record/ByteBufferOutputStream.java
org/apache/kafka/common/record/CompressionType.java
org/apache/kafka/common/record/Compressor.java
org/apache/kafka/common/record/InvalidRecordException.java
org/apache/kafka/common/record/LogEntry.java
org/apache/kafka/common/record/MemoryRecords.java
org/apache/kafka/common/record/Record.java
org/apache/kafka/common/record/Records.java
org/apache/kafka/common/requests/AbstractRequestResponse.java
org/apache/kafka/common/requests/ConsumerMetadataRequest.java
org/apache/kafka/common/requests/ConsumerMetadataResponse.java
org/apache/kafka/common/requests/FetchRequest.java
org/apache/kafka/common/requests/FetchResponse.java
org/apache/kafka/common/requests/HeartbeatRequest.java
org/apache/kafka/common/requests/HeartbeatResponse.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)