Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into trunk
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2d848c5a Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2d848c5a Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2d848c5a Branch: refs/heads/trunk Commit: 2d848c5ae0d10fc4d49ad9a3477b8c46f1c3dab7 Parents: 3f47356 253f86e Author: Sriram Subramanian <[email protected]> Authored: Wed Feb 5 22:06:42 2014 -0800 Committer: Sriram Subramanian <[email protected]> Committed: Wed Feb 5 22:06:42 2014 -0800 ---------------------------------------------------------------------- bin/windows/kafka-run-class.bat | 2 +- clients/build.sbt | 11 + .../producer/BufferExhaustedException.java | 17 + .../java/kafka/clients/producer/Callback.java | 18 + .../kafka/clients/producer/KafkaProducer.java | 286 +++ .../kafka/clients/producer/MockProducer.java | 199 ++ .../java/kafka/clients/producer/Producer.java | 48 + .../kafka/clients/producer/ProducerConfig.java | 130 ++ .../kafka/clients/producer/ProducerRecord.java | 84 + .../kafka/clients/producer/RecordMetadata.java | 39 + .../clients/producer/internals/BufferPool.java | 223 ++ .../internals/FutureRecordMetadata.java | 63 + .../clients/producer/internals/Metadata.java | 120 + .../clients/producer/internals/Partitioner.java | 55 + .../internals/ProduceRequestResult.java | 81 + .../producer/internals/RecordAccumulator.java | 234 ++ .../clients/producer/internals/RecordBatch.java | 86 + .../clients/producer/internals/Sender.java | 504 ++++ .../clients/tools/ProducerPerformance.java | 65 + clients/src/main/java/kafka/common/Cluster.java | 123 + .../main/java/kafka/common/Configurable.java | 15 + .../main/java/kafka/common/KafkaException.java | 26 + clients/src/main/java/kafka/common/Metric.java | 23 + clients/src/main/java/kafka/common/Node.java | 76 + .../main/java/kafka/common/PartitionInfo.java | 58 + .../main/java/kafka/common/TopicPartition.java | 61 + .../kafka/common/config/AbstractConfig.java | 93 + .../java/kafka/common/config/ConfigDef.java | 253 ++ .../kafka/common/config/ConfigException.java | 24 + .../java/kafka/common/errors/ApiException.java | 35 + .../common/errors/CorruptRecordException.java | 23 + .../errors/LeaderNotAvailableException.java | 19 + .../kafka/common/errors/NetworkException.java | 23 + .../errors/NotLeaderForPartitionException.java | 23 + .../common/errors/OffsetMetadataTooLarge.java | 22 + .../errors/OffsetOutOfRangeException.java | 22 + .../common/errors/RecordTooLargeException.java | 23 + .../kafka/common/errors/RetryableException.java | 31 + .../kafka/common/errors/TimeoutException.java | 23 + .../common/errors/UnknownServerException.java | 22 + .../UnknownTopicOrPartitionException.java | 22 + .../java/kafka/common/metrics/CompoundStat.java | 40 + .../java/kafka/common/metrics/JmxReporter.java | 184 ++ .../java/kafka/common/metrics/KafkaMetric.java | 55 + .../java/kafka/common/metrics/Measurable.java | 16 + .../kafka/common/metrics/MeasurableStat.java | 10 + .../java/kafka/common/metrics/MetricConfig.java | 71 + .../main/java/kafka/common/metrics/Metrics.java | 190 ++ .../kafka/common/metrics/MetricsReporter.java | 27 + .../main/java/kafka/common/metrics/Quota.java | 36 + .../common/metrics/QuotaViolationException.java | 16 + .../main/java/kafka/common/metrics/Sensor.java | 171 ++ .../main/java/kafka/common/metrics/Stat.java | 16 + .../java/kafka/common/metrics/stats/Avg.java | 33 + .../java/kafka/common/metrics/stats/Count.java | 29 + .../kafka/common/metrics/stats/Histogram.java | 137 ++ .../java/kafka/common/metrics/stats/Max.java | 29 + .../java/kafka/common/metrics/stats/Min.java | 29 + .../kafka/common/metrics/stats/Percentile.java | 32 + .../kafka/common/metrics/stats/Percentiles.java | 76 + .../java/kafka/common/metrics/stats/Rate.java | 85 + .../kafka/common/metrics/stats/SampledStat.java | 106 + .../java/kafka/common/metrics/stats/Total.java | 31 + .../kafka/common/network/ByteBufferReceive.java | 45 + .../kafka/common/network/ByteBufferSend.java | 54 + .../kafka/common/network/NetworkReceive.java | 74 + .../java/kafka/common/network/NetworkSend.java | 26 + .../main/java/kafka/common/network/Receive.java | 35 + .../java/kafka/common/network/Selectable.java | 68 + .../java/kafka/common/network/Selector.java | 349 +++ .../main/java/kafka/common/network/Send.java | 41 + .../java/kafka/common/protocol/ApiKeys.java | 35 + .../main/java/kafka/common/protocol/Errors.java | 97 + .../java/kafka/common/protocol/ProtoUtils.java | 97 + .../java/kafka/common/protocol/Protocol.java | 130 ++ .../kafka/common/protocol/types/ArrayOf.java | 63 + .../java/kafka/common/protocol/types/Field.java | 48 + .../kafka/common/protocol/types/Schema.java | 134 ++ .../common/protocol/types/SchemaException.java | 13 + .../kafka/common/protocol/types/Struct.java | 227 ++ .../java/kafka/common/protocol/types/Type.java | 216 ++ .../kafka/common/record/CompressionType.java | 40 + .../common/record/InvalidRecordException.java | 11 + .../main/java/kafka/common/record/LogEntry.java | 28 + .../java/kafka/common/record/MemoryRecords.java | 102 + .../main/java/kafka/common/record/Record.java | 286 +++ .../main/java/kafka/common/record/Records.java | 29 + .../kafka/common/requests/RequestHeader.java | 68 + .../java/kafka/common/requests/RequestSend.java | 38 + .../kafka/common/requests/ResponseHeader.java | 45 + .../kafka/common/utils/AbstractIterator.java | 72 + .../java/kafka/common/utils/CopyOnWriteMap.java | 130 ++ .../src/main/java/kafka/common/utils/Crc32.java | 2169 ++++++++++++++++++ .../java/kafka/common/utils/KafkaThread.java | 18 + .../java/kafka/common/utils/SystemTime.java | 26 + .../src/main/java/kafka/common/utils/Time.java | 23 + .../src/main/java/kafka/common/utils/Utils.java | 230 ++ .../clients/common/network/SelectorTest.java | 292 +++ .../kafka/clients/producer/BufferPoolTest.java | 170 ++ .../kafka/clients/producer/MetadataTest.java | 49 + .../clients/producer/MockProducerTest.java | 63 + .../kafka/clients/producer/PartitionerTest.java | 54 + .../clients/producer/RecordAccumulatorTest.java | 135 ++ .../kafka/clients/producer/RecordSendTest.java | 78 + .../java/kafka/clients/producer/SenderTest.java | 87 + .../java/kafka/common/config/ConfigDefTest.java | 88 + .../kafka/common/metrics/JmxReporterTest.java | 21 + .../java/kafka/common/metrics/MetricsTest.java | 176 ++ .../common/metrics/stats/HistogramTest.java | 56 + .../types/ProtocolSerializationTest.java | 96 + .../kafka/common/record/MemoryRecordsTest.java | 44 + .../java/kafka/common/record/RecordTest.java | 87 + .../common/utils/AbstractIteratorTest.java | 54 + .../test/java/kafka/common/utils/MockTime.java | 28 + .../src/test/java/kafka/test/MetricsBench.java | 38 + .../test/java/kafka/test/Microbenchmarks.java | 143 ++ .../src/test/java/kafka/test/MockSelector.java | 87 + clients/src/test/java/kafka/test/TestUtils.java | 95 + contrib/hadoop-consumer/README | 2 +- core/build.sbt | 2 +- .../scala/kafka/consumer/ConsumerConfig.scala | 4 + .../kafka/consumer/ConsumerFetcherManager.scala | 2 +- .../scala/kafka/consumer/SimpleConsumer.scala | 9 +- .../test/scala/unit/kafka/utils/TestUtils.scala | 1 + .../scala/kafka/perf/ConsumerPerformance.scala | 6 + project/Build.scala | 1 + project/build/KafkaProject.scala | 2 +- .../0.7/bin/kafka-run-class.sh | 2 +- 128 files changed, 11752 insertions(+), 11 deletions(-) ----------------------------------------------------------------------
