You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2020/09/24 13:55:08 UTC
[kafka] branch trunk updated (b36e3c2 -> 785de1e)

This is an automated email from the ASF dual-hosted git repository.

mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from b36e3c2  MINOR: Remove `zipWithIndex` to avoid tuple allocation in hot path in `LogValidator` (#9206)
     add 785de1e  KAFKA-9627: Replace ListOffset request/response with automated protocol (#8295)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/admin/KafkaAdminClient.java      |  78 ++++--
 .../kafka/clients/consumer/internals/Fetcher.java  | 165 +++++------
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   6 +-
 .../kafka/common/requests/AbstractResponse.java    |   2 +-
 .../kafka/common/requests/ListOffsetRequest.java   | 303 ++++++---------------
 .../kafka/common/requests/ListOffsetResponse.java  | 262 +++---------------
 .../common/message/ListOffsetRequest.json          |   2 +-
 .../common/message/ListOffsetResponse.json         |   2 +-
 .../kafka/clients/admin/KafkaAdminClientTest.java  | 189 ++++++++-----
 .../kafka/clients/consumer/KafkaConsumerTest.java  |  65 +++--
 .../clients/consumer/internals/FetcherTest.java    | 237 +++++++++++-----
 .../apache/kafka/common/message/MessageTest.java   |  49 ++++
 .../common/requests/ListOffsetRequestTest.java     | 147 ++++++++++
 .../kafka/common/requests/RequestResponseTest.java |  69 +++--
 .../authenticator/SaslAuthenticatorTest.java       |  18 +-
 core/src/main/scala/kafka/cluster/Partition.scala  |   4 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   | 244 +++++++++--------
 .../scala/kafka/server/ReplicaFetcherThread.scala  |  23 +-
 .../kafka/api/AuthorizerIntegrationTest.scala      |  27 +-
 .../kafka/server/DelayedFetchTest.scala            |   4 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   |   4 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  36 ++-
 .../unit/kafka/server/ListOffsetsRequestTest.scala |  41 ++-
 .../scala/unit/kafka/server/LogOffsetTest.scala    |  50 ++--
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  10 +-
 25 files changed, 1124 insertions(+), 913 deletions(-)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/ListOffsetRequestTest.java