You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Raul Castro Fernandez <ra...@contxt.in> on 2014/08/04 20:39:58 UTC
Review Request 24245: Patch for KAFKA-1524
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24245/
-----------------------------------------------------------
Review request for kafka.
Bugs: KAFKA-1524
https://issues.apache.org/jira/browse/KAFKA-1524
Repository: kafka
Description
-------
KAFKA-1524; implement transactional producer
Diffs
-----
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java 522881c972ca42ff4dfb6237a2db15b625334d7e
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 00775abbcac850b0f2bb9a70b6fbc7cdf319bcf6
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 1ed3c28b436d28381d9402896e32d16f2586c65e
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 6fb5b82dedb48d946d1ac1ec7a535bddfdc693fa
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 759f577eaf0e7d28a84926d4aa30f4ef0cb27bc2
clients/src/main/java/org/apache/kafka/common/record/Record.java 10df9fd8d3f4ec8c277650fa7eab269f3ea30d85
clients/src/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java 93b58d02eac0f8ca28440e3e0ebea28ed3a7673c
clients/src/test/java/org/apache/kafka/clients/producer/SenderTest.java 5489acac6806b3ae5e6d568d401d5a20c86cac05
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/24245/diff/
Testing
-------
Thanks,
Raul Castro Fernandez