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 (ad3ccf8 -> c0019e6)
Date Fri, 06 Sep 2019 06:07:57 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 ad3ccf8  KAFKA-8822; Consolidate `PartitionRecords` and `CompletedFetch` types in
Fetcher (#7228)
     add c0019e6  KAFKA-8590; Use automated TxnOffsetCommit type and add tests for OffsetCommit
 (#6994)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   2 +-
 .../producer/internals/TransactionManager.java     |  19 +-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   8 +-
 .../kafka/common/requests/AbstractResponse.java    |   2 +-
 .../kafka/common/requests/OffsetCommitRequest.java |  28 ++-
 .../common/requests/OffsetCommitResponse.java      |  46 ++--
 .../common/requests/TxnOffsetCommitRequest.java    | 266 +++++++--------------
 .../common/requests/TxnOffsetCommitResponse.java   | 150 ++++--------
 .../producer/internals/TransactionManagerTest.java |   6 +-
 .../apache/kafka/common/message/MessageTest.java   | 178 ++++++++++++++
 .../common/requests/OffsetCommitRequestTest.java   | 128 +++++++++-
 .../common/requests/OffsetCommitResponseTest.java  |  99 ++++++++
 .../kafka/common/requests/RequestResponseTest.java |  10 +-
 .../requests/TxnOffsetCommitRequestTest.java       | 109 +++++++++
 .../requests/TxnOffsetCommitResponseTest.java      |  67 ++++++
 core/src/main/scala/kafka/server/KafkaApis.scala   |  19 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  13 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  14 +-
 18 files changed, 820 insertions(+), 344 deletions(-)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitResponseTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitRequestTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitResponseTest.java


Mime
View raw message