kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sriram...@apache.org
Subject [16/19] git commit: Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into trunk
Date Tue, 25 Feb 2014 08:27:26 GMT
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 <sriram.sub@gmail.com>
Authored: Wed Feb 5 22:06:42 2014 -0800
Committer: Sriram Subramanian <sriram.sub@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(-)
----------------------------------------------------------------------



Mime
View raw message