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

Review request for kafka.


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


Repository: kafka


Description
-------

CompressionType is passed in each RecordAccumulator append


Diffs
-----

  clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java 
feda9c922d7dab17e424f8e6f0aa0a3f968e3729 
  
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
 88b4e4fbf3bf6fb6d2f90551a792b95d4cd51c40 
  
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
 e379ac89c9a2fbfe750d6b0dec693b7eabb76204 
  
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
 24274a64885fadd0e9318de2beb232218ddd52cd 

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


Testing
-------


Thanks,

Grant Henke

Reply via email to