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 2021/04/28 15:01:16 UTC

[kafka] branch trunk updated (0ea440b -> 56c7eb6)

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 0ea440b  KAFKA-6435: KIP-623 Add internal topics option to streamResetter (#8923)
     add 56c7eb6  KAFKA-12716; Add `Admin` API to abort transactions (#10599)

No new revisions were added by this update.

Summary of changes:
 .../admin/AbortTransactionOptions.java}            |   7 +-
 ...ordsResult.java => AbortTransactionResult.java} |  26 ++-
 ...roducerState.java => AbortTransactionSpec.java} |  70 +++----
 .../java/org/apache/kafka/clients/admin/Admin.java |  22 +++
 .../kafka/clients/admin/KafkaAdminClient.java      |  10 +
 .../admin/internals/AbortTransactionHandler.java   | 184 +++++++++++++++++
 .../clients/admin/internals/AdminApiHandler.java   |  25 +++
 .../common/requests/WriteTxnMarkersRequest.java    |   5 +
 .../kafka/clients/admin/KafkaAdminClientTest.java  |  92 +++++++++
 .../kafka/clients/admin/MockAdminClient.java       |   5 +
 .../internals/AbortTransactionHandlerTest.java     | 218 +++++++++++++++++++++
 11 files changed, 601 insertions(+), 63 deletions(-)
 copy clients/src/main/java/org/apache/kafka/{server/authorizer/AuthorizationResult.java => clients/admin/AbortTransactionOptions.java} (87%)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DeleteRecordsResult.java => AbortTransactionResult.java} (66%)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{ProducerState.java => AbortTransactionSpec.java} (50%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/internals/AbortTransactionHandler.java
 create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/internals/AbortTransactionHandlerTest.java