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