kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (dc55be2 -> 85f94d5)
Date Tue, 01 Dec 2020 23:56:36 GMT
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(-)


Mime
View raw message