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(-)
