kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Guozhang Wang" <guw...@linkedin.com>
Subject Re: Review Request 18299: Fix KAFKA-1253
Date Mon, 17 Mar 2014 22:56:16 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/18299/
-----------------------------------------------------------

(Updated March 17, 2014, 10:56 p.m.)


Review request for kafka.


Bugs: KAFKA-1253
    https://issues.apache.org/jira/browse/KAFKA-1253


Repository: kafka


Description (updated)
-------

Dummy


Incorporate Jun's comments round four


Dummy


KAFKA-1253.v5


Dummy


Dummy


Dummy


Small fix on ProducerPerformance


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Incorporate Jun's comments one


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy


Dummy 2


Dummy


KAFKA-1253


Diffs (updated)
-----

  build.gradle 84fa0d6b5f7405af755c5d7ff7bdd7592bb8668f 
  clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java 1ac69436f117800815b8d50f042e9e2a29364b43

  clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java 32e12ad149f6d70c96a498d0a390976f77bf9e2a

  clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java 5bed60730ea108684bea2440af5a008feb0ada61

  clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
7a03f389cc6a4d56152b882555d7498af9a04d20 
  clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java 038a05a94b795ec0a95b2d40a89222394b5a74c4

  clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java 3ebbb804242be6a001b3bae6524afccc85a87602

  clients/src/main/java/org/apache/kafka/common/record/ByteBufferInputStream.java PRE-CREATION

  clients/src/main/java/org/apache/kafka/common/record/ByteBufferOutputStream.java PRE-CREATION

  clients/src/main/java/org/apache/kafka/common/record/CompressionFactory.java PRE-CREATION

  clients/src/main/java/org/apache/kafka/common/record/CompressionType.java 906da02d02c03aadd8ab73ed2fc9a1898acb8d72

  clients/src/main/java/org/apache/kafka/common/record/Compressor.java PRE-CREATION 
  clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java 9d8935fa3beeb2a78b109a41ed76fd4374239560

  clients/src/main/java/org/apache/kafka/common/record/Record.java f1dc9778502cbdfe982254fb6e25947842622239

  clients/src/main/java/org/apache/kafka/common/utils/Utils.java 0c6b3656375721a718fb4de10118170aacce0ea9

  clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java b0745b528cef929c4273f7e2ac4de1476cfc25ad

  clients/src/test/java/org/apache/kafka/common/record/RecordTest.java ae54d67da9907b0a043180c7395a1370b3d0528d

  clients/src/test/java/org/apache/kafka/common/utils/CrcTest.java PRE-CREATION 
  clients/src/test/java/org/apache/kafka/test/TestUtils.java 36cfc0fda742eb501af2c2c0330e3f461cf1f40c

  core/src/main/scala/kafka/producer/ConsoleProducer.scala dd39ff22c918fe5b05f04582b748e32349b2055f

  core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala PRE-CREATION 
  core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala c002f5ea38ece66ad559fadb18ffaf40ac2026aa

  core/src/test/scala/integration/kafka/api/ProducerSendTest.scala 66ea76b9b6c0f8839f715c845fb9b9671b8f35c1

  perf/src/main/scala/kafka/perf/ProducerPerformance.scala f12a45becb11a8bed586024866235b268630fec6


Diff: https://reviews.apache.org/r/18299/diff/


Testing
-------

integration tests

unit tests

stress tests (1K message size, 1M messages in producer performance with ack = 1, linger time
= 0ms/500ms, random bit/all-ones messages)

snappy dynamic load test


Thanks,

Guozhang Wang


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message