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 2020/01/22 21:49:40 UTC

[kafka] branch trunk updated (b399a73 -> de90175)

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 b399a73  KAFKA-7273 Clarification on mutability of headers passed to Converter#fromConnectData() (#7489)
     add de90175  KAFKA-9418; Add new sendOffsetsToTransaction API to KafkaProducer (#7952)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   4 +-
 .../clients/consumer/ConsumerGroupMetadata.java    |  32 ++-
 .../kafka/clients/producer/KafkaProducer.java      |  57 +++++-
 .../kafka/clients/producer/MockProducer.java       |  10 +-
 .../apache/kafka/clients/producer/Producer.java    |   7 +
 .../producer/internals/TransactionManager.java     |  58 ++++--
 .../common/requests/TxnOffsetCommitRequest.java    |  36 +++-
 .../consumer/ConsumerGroupMetadataTest.java        |  45 +++-
 .../internals/PartitionAssignorAdapterTest.java    |   3 +-
 .../kafka/clients/producer/KafkaProducerTest.java  | 145 +++++++++++++
 .../kafka/clients/producer/MockProducerTest.java   | 138 +++++++++++--
 .../producer/internals/TransactionManagerTest.java | 228 ++++++++++++++++++++-
 .../apache/kafka/common/message/MessageTest.java   |   6 +-
 .../common/requests/OffsetCommitRequestTest.java   |   8 +-
 .../kafka/common/requests/RequestResponseTest.java |  37 ++--
 .../requests/TxnOffsetCommitRequestTest.java       |  86 ++++----
 .../kafka/api/TransactionsBounceTest.scala         |  18 +-
 .../integration/kafka/api/TransactionsTest.scala   |  23 ++-
 .../coordinator/group/GroupCoordinatorTest.scala   |  57 ++++--
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  13 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  14 +-
 21 files changed, 868 insertions(+), 157 deletions(-)