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 2022/09/13 03:51:00 UTC

[kafka] branch trunk updated (d4fc3186b40 -> b9774c0b025)

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 d4fc3186b40 MINOR: Replace usage of File.createTempFile() with TestUtils.tempFile() (#12591)
     add b9774c0b025 KAFKA-14215; Ensure forwarded requests are applied to broker request quota (#12624)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/requests/AbstractResponse.java    | 12 +++++
 .../common/requests/AddOffsetsToTxnResponse.java   |  5 ++
 .../requests/AddPartitionsToTxnResponse.java       |  5 ++
 .../requests/AllocateProducerIdsResponse.java      |  5 ++
 .../common/requests/AlterClientQuotasResponse.java |  5 ++
 .../common/requests/AlterConfigsResponse.java      |  5 ++
 .../AlterPartitionReassignmentsResponse.java       |  5 ++
 .../common/requests/AlterPartitionResponse.java    |  5 ++
 .../requests/AlterReplicaLogDirsResponse.java      |  5 ++
 .../AlterUserScramCredentialsResponse.java         |  5 ++
 .../kafka/common/requests/ApiVersionsResponse.java |  5 ++
 .../common/requests/BeginQuorumEpochResponse.java  |  5 ++
 .../common/requests/BrokerHeartbeatResponse.java   |  5 ++
 .../requests/BrokerRegistrationResponse.java       |  5 ++
 .../requests/ControlledShutdownResponse.java       |  5 ++
 .../kafka/common/requests/CreateAclsResponse.java  |  5 ++
 .../requests/CreateDelegationTokenResponse.java    |  5 ++
 .../common/requests/CreatePartitionsResponse.java  |  5 ++
 .../common/requests/CreateTopicsResponse.java      |  5 ++
 .../kafka/common/requests/DeleteAclsResponse.java  |  5 ++
 .../common/requests/DeleteGroupsResponse.java      |  5 ++
 .../common/requests/DeleteRecordsResponse.java     |  5 ++
 .../common/requests/DeleteTopicsResponse.java      |  5 ++
 .../common/requests/DescribeAclsResponse.java      |  5 ++
 .../requests/DescribeClientQuotasResponse.java     |  5 ++
 .../common/requests/DescribeClusterResponse.java   |  5 ++
 .../common/requests/DescribeConfigsResponse.java   |  5 ++
 .../requests/DescribeDelegationTokenResponse.java  |  5 ++
 .../common/requests/DescribeGroupsResponse.java    |  5 ++
 .../common/requests/DescribeLogDirsResponse.java   |  5 ++
 .../common/requests/DescribeProducersResponse.java |  5 ++
 .../common/requests/DescribeQuorumResponse.java    |  5 ++
 .../requests/DescribeTransactionsResponse.java     |  6 +++
 .../DescribeUserScramCredentialsResponse.java      |  5 ++
 .../common/requests/ElectLeadersResponse.java      |  5 ++
 .../common/requests/EndQuorumEpochResponse.java    |  5 ++
 .../kafka/common/requests/EndTxnResponse.java      |  4 ++
 .../kafka/common/requests/EnvelopeResponse.java    |  5 ++
 .../requests/ExpireDelegationTokenResponse.java    |  5 ++
 .../kafka/common/requests/FetchResponse.java       |  5 ++
 .../common/requests/FetchSnapshotResponse.java     |  5 ++
 .../common/requests/FindCoordinatorResponse.java   |  5 ++
 .../kafka/common/requests/HeartbeatResponse.java   |  5 ++
 .../requests/IncrementalAlterConfigsResponse.java  |  5 ++
 .../common/requests/InitProducerIdResponse.java    |  5 ++
 .../kafka/common/requests/JoinGroupResponse.java   |  5 ++
 .../common/requests/LeaderAndIsrResponse.java      |  5 ++
 .../kafka/common/requests/LeaveGroupResponse.java  |  5 ++
 .../kafka/common/requests/ListGroupsResponse.java  |  5 ++
 .../kafka/common/requests/ListOffsetsResponse.java |  5 ++
 .../ListPartitionReassignmentsResponse.java        |  5 ++
 .../common/requests/ListTransactionsResponse.java  |  5 ++
 .../kafka/common/requests/MetadataResponse.java    |  5 ++
 .../common/requests/OffsetCommitResponse.java      |  5 ++
 .../common/requests/OffsetDeleteResponse.java      |  5 ++
 .../kafka/common/requests/OffsetFetchResponse.java |  5 ++
 .../requests/OffsetsForLeaderEpochResponse.java    |  5 ++
 .../kafka/common/requests/ProduceResponse.java     |  5 ++
 .../requests/RenewDelegationTokenResponse.java     |  5 ++
 .../common/requests/SaslAuthenticateResponse.java  |  5 ++
 .../common/requests/SaslHandshakeResponse.java     |  5 ++
 .../kafka/common/requests/StopReplicaResponse.java |  5 ++
 .../kafka/common/requests/SyncGroupResponse.java   |  5 ++
 .../common/requests/TxnOffsetCommitResponse.java   |  5 ++
 .../common/requests/UnregisterBrokerResponse.java  |  5 ++
 .../common/requests/UpdateFeaturesResponse.java    |  5 ++
 .../common/requests/UpdateMetadataResponse.java    |  5 ++
 .../apache/kafka/common/requests/VoteResponse.java |  5 ++
 .../common/requests/WriteTxnMarkersResponse.java   |  5 ++
 .../scala/kafka/server/RequestHandlerHelper.scala  | 11 +++--
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 55 +++++++++++++++++++++-
 71 files changed, 412 insertions(+), 6 deletions(-)