You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sr...@apache.org on 2014/02/25 09:27:26 UTC
[16/19] git commit: Merge branch 'trunk' of
http://git-wip-us.apache.org/repos/asf/kafka into trunk
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 <sr...@gmail.com>
Authored: Wed Feb 5 22:06:42 2014 -0800
Committer: Sriram Subramanian <sr...@gmail.com>
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(-)
----------------------------------------------------------------------