kafka-clients-0.8.2-beta-sources.jar

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

org.apache.kafka:kafka-clients:0.8.2-beta

META-INF/MANIFEST.MF
LICENSE
NOTICE
org/apache/kafka/common/Node.java
org/apache/kafka/common/TopicPartition.java
org/apache/kafka/common/KafkaException.java
org/apache/kafka/common/Cluster.java
org/apache/kafka/common/Configurable.java
org/apache/kafka/common/PartitionInfo.java
org/apache/kafka/common/Metric.java
org/apache/kafka/common/requests/ProduceRequest.java
org/apache/kafka/common/requests/HeartbeatResponse.java
org/apache/kafka/common/requests/MetadataRequest.java
org/apache/kafka/common/requests/MetadataResponse.java
org/apache/kafka/common/requests/RequestHeader.java
org/apache/kafka/common/requests/OffsetCommitRequest.java
org/apache/kafka/common/requests/ListOffsetResponse.java
org/apache/kafka/common/requests/FetchResponse.java
org/apache/kafka/common/requests/ConsumerMetadataRequest.java
org/apache/kafka/common/requests/JoinGroupRequest.java
org/apache/kafka/common/requests/OffsetCommitResponse.java
org/apache/kafka/common/requests/HeartbeatRequest.java
org/apache/kafka/common/requests/ConsumerMetadataResponse.java
org/apache/kafka/common/requests/AbstractRequestResponse.java
org/apache/kafka/common/requests/JoinGroupResponse.java
org/apache/kafka/common/requests/OffsetFetchRequest.java
org/apache/kafka/common/requests/ResponseHeader.java
org/apache/kafka/common/requests/FetchRequest.java
org/apache/kafka/common/requests/ProduceResponse.java
org/apache/kafka/common/requests/RequestSend.java
org/apache/kafka/common/requests/ListOffsetRequest.java
org/apache/kafka/common/requests/OffsetFetchResponse.java
org/apache/kafka/common/message/KafkaLZ4BlockOutputStream.java
org/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
org/apache/kafka/common/utils/AbstractIterator.java
org/apache/kafka/common/utils/KafkaThread.java
org/apache/kafka/common/utils/Time.java
org/apache/kafka/common/utils/ClientUtils.java
org/apache/kafka/common/utils/CollectionUtils.java
org/apache/kafka/common/utils/CopyOnWriteMap.java
org/apache/kafka/common/utils/Utils.java
org/apache/kafka/common/utils/SystemTime.java
org/apache/kafka/common/utils/Crc32.java
org/apache/kafka/common/errors/UnknownServerException.java
org/apache/kafka/common/errors/OffsetMetadataTooLarge.java
org/apache/kafka/common/errors/RecordTooLargeException.java
org/apache/kafka/common/errors/NotEnoughReplicasException.java
org/apache/kafka/common/errors/RecordBatchTooLargeException.java
org/apache/kafka/common/errors/CorruptRecordException.java
org/apache/kafka/common/errors/NotLeaderForPartitionException.java
org/apache/kafka/common/errors/ApiException.java
org/apache/kafka/common/errors/NetworkException.java
org/apache/kafka/common/errors/OffsetOutOfRangeException.java
org/apache/kafka/common/errors/InvalidMetadataException.java
org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java
org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java
org/apache/kafka/common/errors/LeaderNotAvailableException.java
org/apache/kafka/common/errors/TimeoutException.java
org/apache/kafka/common/errors/RetriableException.java
org/apache/kafka/common/errors/InvalidTopicException.java
org/apache/kafka/common/protocol/Protocol.java
org/apache/kafka/common/protocol/ProtoUtils.java
org/apache/kafka/common/protocol/ApiKeys.java
org/apache/kafka/common/protocol/Errors.java
org/apache/kafka/common/protocol/types/Field.java
org/apache/kafka/common/protocol/types/Struct.java
org/apache/kafka/common/protocol/types/SchemaException.java
org/apache/kafka/common/protocol/types/ArrayOf.java
org/apache/kafka/common/protocol/types/Schema.java
org/apache/kafka/common/protocol/types/Type.java
org/apache/kafka/common/record/ByteBufferOutputStream.java
org/apache/kafka/common/record/Records.java
org/apache/kafka/common/record/ByteBufferInputStream.java
org/apache/kafka/common/record/CompressionType.java
org/apache/kafka/common/record/LogEntry.java
org/apache/kafka/common/record/Record.java
org/apache/kafka/common/record/MemoryRecords.java
org/apache/kafka/common/record/Compressor.java
org/apache/kafka/common/record/InvalidRecordException.java
org/apache/kafka/common/metrics/Quota.java
org/apache/kafka/common/metrics/KafkaMetric.java
org/apache/kafka/common/metrics/Stat.java
org/apache/kafka/common/metrics/JmxReporter.java
org/apache/kafka/common/metrics/Metrics.java
org/apache/kafka/common/metrics/MeasurableStat.java
org/apache/kafka/common/metrics/QuotaViolationException.java
org/apache/kafka/common/metrics/Measurable.java
org/apache/kafka/common/metrics/MetricConfig.java
org/apache/kafka/common/metrics/Sensor.java
org/apache/kafka/common/metrics/CompoundStat.java
org/apache/kafka/common/metrics/MetricsReporter.java
org/apache/kafka/common/metrics/stats/Min.java
org/apache/kafka/common/metrics/stats/SampledStat.java
org/apache/kafka/common/metrics/stats/Count.java
org/apache/kafka/common/metrics/stats/Percentile.java
org/apache/kafka/common/metrics/stats/Total.java
org/apache/kafka/common/metrics/stats/Max.java
org/apache/kafka/common/metrics/stats/Percentiles.java
org/apache/kafka/common/metrics/stats/Rate.java
org/apache/kafka/common/metrics/stats/Avg.java
org/apache/kafka/common/metrics/stats/Histogram.java
org/apache/kafka/common/network/NetworkReceive.java
org/apache/kafka/common/network/NetworkSend.java
org/apache/kafka/common/network/ByteBufferReceive.java
org/apache/kafka/common/network/Selector.java
org/apache/kafka/common/network/Send.java
org/apache/kafka/common/network/Receive.java
org/apache/kafka/common/network/Selectable.java
org/apache/kafka/common/network/ByteBufferSend.java
org/apache/kafka/common/config/ConfigDef.java
org/apache/kafka/common/config/ConfigException.java
org/apache/kafka/common/config/AbstractConfig.java
org/apache/kafka/clients/NodeConnectionState.java
org/apache/kafka/clients/InFlightRequests.java
org/apache/kafka/clients/ClusterConnectionStates.java
org/apache/kafka/clients/ConnectionState.java
org/apache/kafka/clients/ClientRequest.java
org/apache/kafka/clients/ClientResponse.java
org/apache/kafka/clients/KafkaClient.java
org/apache/kafka/clients/NetworkClient.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)