Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

[transactions] Implement KIP-664 DescribeProducers #1986

Draft
wants to merge 4 commits into
base: master
Choose a base branch
from

Conversation

gaoran10
Copy link
Contributor

@gaoran10 gaoran10 commented Jul 30, 2023

This PR needs #1985.

Motivation

Implement KIP-664 DescribeProducers.

Modifications

Handle the command DESCRIBE_PRODUCERS.

Documentation

Check the box below.

Need to update docs?

  • doc-required

    (If you need help on updating docs, create a doc issue)

  • no-need-doc

    (Please explain why)

  • doc

    (If this PR contains doc changes)

@codecov
Copy link

codecov bot commented Jul 30, 2023

Codecov Report

Merging #1986 (d60d786) into master (e931b6d) will decrease coverage by 0.50%.
Report is 2 commits behind head on master.
The diff coverage is 0.20%.

Impacted file tree graph

@@             Coverage Diff              @@
##             master    #1986      +/-   ##
============================================
- Coverage     17.72%   17.22%   -0.50%     
  Complexity      751      751              
============================================
  Files           195      195              
  Lines         14156    14568     +412     
  Branches       1322     1352      +30     
============================================
+ Hits           2509     2510       +1     
- Misses        11464    11875     +411     
  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%) ⬇️
...ative/pulsar/handlers/kop/KafkaRequestHandler.java 0.94% <0.00%> (-0.12%) ⬇️
...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

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants