streamnative / kop

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
https://streamnative.io/docs/kop
Apache License 2.0
450 stars 136 forks source link

[transaction] Add test for aborting transactions by admin #1987

Open gaoran10 opened 1 year ago

gaoran10 commented 1 year ago

This PR needs https://github.com/streamnative/kop/pull/1986.

Modifications

Add test for aborting transactions by admin.

Documentation

Check the box below.

Need to update docs?

codecov[bot] commented 1 year ago

Codecov Report

Merging #1987 (0ec6d7f) into master (e931b6d) will decrease coverage by 0.50%. Report is 5 commits behind head on master. The diff coverage is 0.20%.

Impacted file tree graph

@@             Coverage Diff              @@
##             master    #1987      +/-   ##
============================================
- Coverage     17.72%   17.22%   -0.50%     
  Complexity      751      751              
============================================
  Files           195      195              
  Lines         14156    14569     +413     
  Branches       1322     1353      +31     
============================================
+ Hits           2509     2510       +1     
- Misses        11464    11876     +412     
  Partials        183      183              
Files Changed Coverage Δ
...streamnative/pulsar/handlers/kop/DelayedFetch.java 0.00% <ø> (ø)
...ative/pulsar/handlers/kop/KafkaCommandDecoder.java 0.31% <0.00%> (-0.02%) :arrow_down:
...ative/pulsar/handlers/kop/KafkaRequestHandler.java 0.94% <0.00%> (-0.12%) :arrow_down:
...ndlers/kop/coordinator/group/GroupCoordinator.java 0.00% <0.00%> (ø)
...oordinator/transaction/TransactionCoordinator.java 0.00% <0.00%> (ø)
.../kop/coordinator/transaction/TransactionState.java 0.00% <0.00%> (ø)
...ordinator/transaction/TransactionStateManager.java 0.00% <0.00%> (ø)
...sar/handlers/kop/storage/AppendRecordsContext.java 0.00% <0.00%> (ø)
...sar/handlers/kop/storage/ProducerStateManager.java 0.00% <0.00%> (ø)
...ve/pulsar/handlers/kop/storage/ReplicaManager.java 0.00% <0.00%> (ø)
... and 3 more

... and 7 files with indirect coverage changes