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 dc55be2 KAFKA-6687: restrict DSL to allow only Streams from the same
source topics (#9609)
add 85f94d5 KAFKA-10729; Bump remaining RPC's to use tagged fields.
(#9601)
No new revisions were added by this update.
Summary of changes:
.../kafka/common/requests/AbstractResponse.java | 2 +-
.../common/requests/AlterReplicaLogDirsResponse.java | 6 +-----
.../apache/kafka/common/requests/ProduceRequest.java | 19 +++++--------------
.../kafka/common/requests/WriteTxnMarkersRequest.java | 4 ++--
.../common/message/AddOffsetsToTxnRequest.json | 6 ++++--
.../common/message/AddOffsetsToTxnResponse.json | 6 ++++--
.../common/message/AddPartitionsToTxnRequest.json | 6 ++++--
.../common/message/AddPartitionsToTxnResponse.json | 6 ++++--
.../common/message/AlterClientQuotasRequest.json | 5 +++--
.../common/message/AlterClientQuotasResponse.json | 5 +++--
.../resources/common/message/AlterConfigsRequest.json | 5 +++--
.../common/message/AlterConfigsResponse.json | 5 +++--
.../common/message/AlterReplicaLogDirsRequest.json | 5 +++--
.../common/message/AlterReplicaLogDirsResponse.json | 5 +++--
.../common/message/DescribeClientQuotasRequest.json | 5 +++--
.../common/message/DescribeClientQuotasResponse.json | 6 +++---
.../common/message/DescribeConfigsRequest.json | 5 +++--
.../common/message/DescribeConfigsResponse.json | 5 +++--
.../main/resources/common/message/EndTxnRequest.json | 6 ++++--
.../main/resources/common/message/EndTxnResponse.json | 6 ++++--
.../resources/common/message/ListOffsetRequest.json | 8 +++++---
.../resources/common/message/ListOffsetResponse.json | 6 ++++--
.../common/message/OffsetForLeaderEpochRequest.json | 6 ++++--
.../common/message/OffsetForLeaderEpochResponse.json | 6 ++++--
.../main/resources/common/message/ProduceRequest.json | 6 ++++--
.../resources/common/message/ProduceResponse.json | 6 ++++--
.../common/message/WriteTxnMarkersRequest.json | 5 +++--
.../common/message/WriteTxnMarkersResponse.json | 5 +++--
.../org/apache/kafka/clients/NetworkClientTest.java | 10 +++++-----
.../kafka/common/requests/RequestResponseTest.java | 10 +++++-----
.../common/requests/WriteTxnMarkersRequestTest.java | 4 ++--
core/src/main/scala/kafka/api/ApiVersion.scala | 11 ++++++++++-
.../transaction/TransactionMarkerChannelManager.scala | 7 ++++++-
.../scala/kafka/server/ReplicaFetcherThread.scala | 6 ++++--
.../test/scala/unit/kafka/api/ApiVersionTest.scala | 4 ++++
.../TransactionMarkerChannelManagerTest.scala | 8 ++++----
.../scala/unit/kafka/server/EdgeCaseRequestTest.scala | 13 +++++++++----
.../test/scala/unit/kafka/server/KafkaApisTest.scala | 5 ++---
.../unit/kafka/server/ReplicaFetcherThreadTest.scala | 4 ++--
.../scala/unit/kafka/server/RequestQuotaTest.scala | 2 +-
40 files changed, 148 insertions(+), 102 deletions(-)
