You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2021/04/05 18:52:50 UTC
[kafka] branch trunk updated (4f47a56 -> 66ba917)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 4f47a56 KAFKA-12539; Refactor KafkaRaftCllient handleVoteRequest to reduce cyclomatic complexity (#10393)
add 66ba917 KAFKA-12548; Propagate record error messages to application (#10445)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/producer/MockProducer.java | 7 +-
.../producer/internals/FutureRecordMetadata.java | 13 +--
.../producer/internals/ProduceRequestResult.java | 18 +++--
.../clients/producer/internals/ProducerBatch.java | 83 ++++++++++++++-----
.../kafka/clients/producer/internals/Sender.java | 93 +++++++++++++++++-----
.../resources/common/message/ProduceRequest.json | 2 +-
.../resources/common/message/ProduceResponse.json | 6 +-
.../kafka/clients/producer/RecordSendTest.java | 9 ++-
.../producer/internals/ProducerBatchTest.java | 75 ++++++++++++++---
.../producer/internals/RecordAccumulatorTest.java | 6 +-
.../clients/producer/internals/SenderTest.java | 91 ++++++++++++++++++---
.../producer/internals/TransactionManagerTest.java | 18 ++---
.../kafka/api/PlaintextProducerSendTest.scala | 2 -
13 files changed, 326 insertions(+), 97 deletions(-)