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

Review request for kafka.


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


Repository: kafka


Description
-------

KAFKA-1524; transactional producer


Diffs
-----

  clients/src/main/java/org/apache/kafka/clients/NetworkClient.java 
eea270abb16f40c9f3b47c4ea96be412fb4fdc8b 
  
clients/src/main/java/org/apache/kafka/clients/producer/AbortTransactionException.java
 PRE-CREATION 
  
clients/src/main/java/org/apache/kafka/clients/producer/InvalidTransactionStatusException.java
 PRE-CREATION 
  clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java 
f58b8508d3f813a51015abed772c704390887d7e 
  clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java 
c0f1d57e0feb894d9f246058cd0396461afe3225 
  clients/src/main/java/org/apache/kafka/clients/producer/Producer.java 
36e8398416036cab84faad1f07159e5adefd8086 
  clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java 
f9de4af426449cceca12a8de9a9f54a6241d28d8 
  
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
 c5d470011d334318d5ee801021aadd0c000974a6 
  
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java
 dd0af8aee98abed5d4a0dc50989e37888bb353fe 
  clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java 
8ebe7ed82c9384b71ce0cc3ddbef2c2325363ab9 
  
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionContext.java
 PRE-CREATION 
  
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionControl.java
 PRE-CREATION 
  
clients/src/main/java/org/apache/kafka/common/errors/TransactionCoordinatorNotAvailableException.java
 PRE-CREATION 
  
clients/src/main/java/org/apache/kafka/common/errors/TransactionFailedException.java
 PRE-CREATION 
  clients/src/main/java/org/apache/kafka/common/record/Compressor.java 
0323f5f7032dceb49d820c17a41b78c56591ffc4 
  clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java 
040e5b91005edb8f015afdfa76fd94e0bf3cb4ca 
  clients/src/main/java/org/apache/kafka/common/record/Record.java 
10df9fd8d3f4ec8c277650fa7eab269f3ea30d85 
  
clients/src/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java
 0762b35abba0551f23047348c5893bb8c9acff14 
  clients/src/test/java/org/apache/kafka/clients/producer/SenderTest.java 
ef2ca65cabe97b909f17b62027a1bb06827e88fe 
  
clients/src/test/java/org/apache/kafka/clients/producer/TransactionContextTest.java
 PRE-CREATION 
  clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java 
94a11121e207d5cf94dbc94443a8aa7edf387782 

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


Testing
-------


Thanks,

Raul Castro Fernandez

Reply via email to