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 2020/11/18 21:45:39 UTC
[kafka] branch trunk updated (b3264b7 -> 30bc21c)

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 b3264b7  MINOR: Unifies implementations for commitSync (#6319)
     add 30bc21c  KAFKA-9628; Replace Produce request/response with automated protocol (#9401)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/producer/internals/Sender.java   |  42 ++-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   6 +-
 .../apache/kafka/common/protocol/CommonFields.java |  10 -
 .../kafka/common/requests/AbstractRequest.java     |   3 +-
 .../kafka/common/requests/AbstractResponse.java    |   3 +-
 .../kafka/common/requests/ProduceRequest.java      | 389 +++++++--------------
 .../kafka/common/requests/ProduceResponse.java     | 372 +++++++-------------
 .../apache/kafka/common/requests/RequestUtils.java |  42 +++
 .../resources/common/message/ProduceRequest.json   |  12 +-
 .../resources/common/message/ProduceResponse.json  |   8 +-
 .../apache/kafka/clients/NetworkClientTest.java    |  58 +--
 .../clients/producer/internals/SenderTest.java     |  53 ++-
 .../producer/internals/TransactionManagerTest.java |  12 +-
 .../apache/kafka/common/message/MessageTest.java   |  61 ++--
 .../kafka/common/requests/ProduceRequestTest.java  | 189 ++++++----
 .../kafka/common/requests/ProduceResponseTest.java |   9 +-
 .../kafka/common/requests/RequestResponseTest.java |  52 ++-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  30 +-
 .../kafka/api/AuthorizerIntegrationTest.scala      |  21 +-
 .../kafka/network/DynamicConnectionQuotaTest.scala |  27 +-
 .../unit/kafka/network/SocketServerTest.scala      |  41 ++-
 .../unit/kafka/server/EdgeCaseRequestTest.scala    |  23 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  17 +-
 .../unit/kafka/server/ProduceRequestTest.scala     |  74 +++-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  21 +-
 .../jmh/producer/ProducerRequestBenchmark.java     |  93 +++++
 .../jmh/producer/ProducerResponseBenchmark.java    |  88 +++++
 27 files changed, 997 insertions(+), 759 deletions(-)
 create mode 100644 jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRequestBenchmark.java
 create mode 100644 jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerResponseBenchmark.java