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
