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

Conversation

Demogorgon314
Copy link
Member

This PR is cherry-picking from datastax/starlight-for-kafka@e0636995

Motivation

Complete the pending request features when the channel is Inactive, or the exception caught.

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 Jun 16, 2023

Codecov Report

Merging #1907 (c0bad1a) into master (08c0a9b) will decrease coverage by 0.44%.
The diff coverage is 0.00%.

Impacted file tree graph

@@             Coverage Diff              @@
##             master    #1907      +/-   ##
============================================
- Coverage     18.76%   18.33%   -0.44%     
- Complexity      742      743       +1     
============================================
  Files           185      190       +5     
  Lines         13266    13605     +339     
  Branches       1213     1260      +47     
============================================
+ Hits           2490     2494       +4     
- Misses        10594    10930     +336     
+ Partials        182      181       -1     
Impacted Files Coverage Δ
...tive/pulsar/handlers/kop/KafkaProtocolHandler.java 0.00% <0.00%> (ø)
...pulsar/handlers/kop/KafkaTopicConsumerManager.java 0.00% <0.00%> (ø)
...lers/kop/NamespaceBundleOwnershipListenerImpl.java 0.00% <0.00%> (ø)
...ve/pulsar/handlers/kop/TopicEventListenerImpl.java 0.00% <0.00%> (ø)
...ve/pulsar/handlers/kop/TopicOwnershipListener.java 0.00% <0.00%> (ø)
...rs/kop/coordinator/transaction/PendingRequest.java 0.00% <0.00%> (ø)
...oordinator/transaction/TransactionCoordinator.java 0.00% <0.00%> (ø)
...r/transaction/TransactionMarkerChannelHandler.java 0.00% <0.00%> (ø)
...ion/TransactionMarkerRequestCompletionHandler.java 0.00% <ø> (ø)
...ordinator/transaction/TransactionStateManager.java 0.00% <0.00%> (ø)

... and 9 files with indirect coverage changes

@Demogorgon314
Copy link
Member Author

@gaoran10 @BewareMyPower @yzang2019 Please help review this PR : )

@Demogorgon314 Demogorgon314 merged commit 8287e60 into streamnative:master Jun 28, 2023
2 of 4 checks passed
@Demogorgon314 Demogorgon314 deleted the s4k/Better_handling_of_network_exceptions_while_sending_TX_markers branch June 28, 2023 12:17
BewareMyPower pushed a commit that referenced this pull request Jun 29, 2023
… markers (#1907)

This PR is cherry-picking from
datastax/starlight-for-kafka@e0636995

### Motivation

Complete the pending request features when the channel is Inactive, or
the exception caught.

Co-authored-by: Enrico Olivelli <[email protected]>
(cherry picked from commit 8287e60)
BewareMyPower pushed a commit that referenced this pull request Jul 3, 2023
… markers (#1907)

This PR is cherry-picking from
datastax/starlight-for-kafka@e0636995

### Motivation

Complete the pending request features when the channel is Inactive, or
the exception caught.

Co-authored-by: Enrico Olivelli <[email protected]>
(cherry picked from commit 8287e60)
Demogorgon314 added a commit to Demogorgon314/kop that referenced this pull request Aug 14, 2023
… markers (streamnative#1907)

This PR is cherry-picking from
datastax/starlight-for-kafka@e0636995

### Motivation

Complete the pending request features when the channel is Inactive, or
the exception caught.

Co-authored-by: Enrico Olivelli <[email protected]>
(cherry picked from commit 8287e60)
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants