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

Fix the incompatibility with Pulsar 3.0.0.1-SNAPSHOT - #1759

Merged
Demogorgon314 merged 7 commits into
streamnative:masterfrom
BewareMyPower:bewaremypower/3.0.0.1-snapshot
Mar 7, 2023
Merged

Fix the incompatibility with Pulsar 3.0.0.1-SNAPSHOT#1759
Demogorgon314 merged 7 commits into
streamnative:masterfrom
BewareMyPower:bewaremypower/3.0.0.1-snapshot

Conversation

@BewareMyPower

@BewareMyPower BewareMyPower commented Mar 6, 2023

Copy link
Copy Markdown
Contributor

Modifications

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)

### Modifications

- Upgrade the Pulsar dependency to 3.0.0.1-SNAPSHOT
- Use `List<EntryFilter>` from
  apache/pulsar#19364 as the filters
- Remove the removed APIs in `AuthorizationService`
- Use `TopicType` instead of String.
@BewareMyPower BewareMyPower self-assigned this Mar 6, 2023
@github-actions github-actions Bot added the no-need-doc This pr does not need any document label Mar 6, 2023
coderzc
coderzc previously approved these changes Mar 6, 2023
@codecov

codecov Bot commented Mar 7, 2023

Copy link
Copy Markdown

Codecov Report

Merging #1759 (a347c99) into master (7994cd6) will increase coverage by 0.01%.
The diff coverage is 39.28%.

Impacted file tree graph

@@             Coverage Diff              @@
##             master    #1759      +/-   ##
============================================
+ Coverage     16.04%   16.05%   +0.01%     
- Complexity      625      626       +1     
============================================
  Files           165      165              
  Lines         12309    12311       +2     
  Branches       1128     1128              
============================================
+ Hits           1975     1977       +2     
- Misses        10170    10171       +1     
+ Partials        164      163       -1     
Impacted Files Coverage Δ
...tive/pulsar/handlers/kop/KafkaProtocolHandler.java 0.00% <0.00%> (ø)
...ive/pulsar/handlers/kop/SchemaRegistryManager.java 0.00% <0.00%> (ø)
.../handlers/kop/format/KafkaMixedEntryFormatter.java 96.87% <ø> (ø)
...sar/handlers/kop/format/KafkaV1EntryFormatter.java 95.00% <ø> (ø)
...ulsar/handlers/kop/security/SaslAuthenticator.java 0.00% <0.00%> (ø)
.../security/oauth/OauthValidatorCallbackHandler.java 0.00% <0.00%> (ø)
...lsar/handlers/kop/storage/PartitionLogManager.java 0.00% <0.00%> (ø)
...ve/pulsar/handlers/kop/storage/ReplicaManager.java 0.00% <0.00%> (ø)
...tive/pulsar/handlers/kop/storage/PartitionLog.java 10.22% <50.00%> (ø)
.../pulsar/handlers/kop/security/PlainSaslServer.java 46.55% <83.33%> (+0.93%) ⬆️
... and 6 more

@Demogorgon314
Demogorgon314 merged commit 7faa3f4 into streamnative:master Mar 7, 2023
@BewareMyPower
BewareMyPower deleted the bewaremypower/3.0.0.1-snapshot branch March 7, 2023 15:37
BewareMyPower added a commit that referenced this pull request Jul 1, 2023
### Motivation

When running `GroupMetadataManagerTest`,
`testOffsetWriteAfterGroupRemoved` will be called after
`testOffsetTopicNumPartitionsModify`, which changes the
`offsetTopicNumPartitions` to 100 so that `consumerGroupPartitionId`
will be 74 while `groupPartitionId` is 0, and then the group metadata
will be sent to partition 0 while `scheduleLoadGroupAndOffsets` will
read from partition 74. Since no group metadata is loaded,

### Modifications

Migrate the fix in #1759 to
reset the `offsetTopicNumPartitions` before and after each method.
Demogorgon314 pushed a commit that referenced this pull request Jul 2, 2023
### Motivation

When running `GroupMetadataManagerTest`,
`testOffsetWriteAfterGroupRemoved` will be called after
`testOffsetTopicNumPartitionsModify`, which changes the
`offsetTopicNumPartitions` to 100 so that `consumerGroupPartitionId`
will be 74 while `groupPartitionId` is 0, and then the group metadata
will be sent to partition 0 while `scheduleLoadGroupAndOffsets` will
read from partition 74. Since no group metadata is loaded,

### Modifications

Migrate the fix in #1759 to
reset the `offsetTopicNumPartitions` before and after each method.
BewareMyPower pushed a commit that referenced this pull request Jul 17, 2023
…1923)

### Motivation

Cherry-pick s4k transaction producer state manager snapshot recovery
feature.

### Modifications

* Support producer state manager recovery

Co-authored-by: Enrico Olivelli <enrico.olivelli@datastax.com>
Co-authored-by: Michael Marshall <mmarshall@apache.org>
(cherry picked from commit fcf5234)

Fix conflicts caused by #1759
Demogorgon314 pushed a commit to Demogorgon314/kop that referenced this pull request Apr 15, 2026
…scribeConsumerGroupTest (streamnative#1760)

Fixes streamnative#1759

When the Kafka admin client is configured with a small request timeout
(1ms), calling `close()` could be blocked for long (5 minutes) because
the RPC will always fail with timeout and retry. In this case, we only
need to call `close` with a small timeout to close some resources.
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

area/build no-need-doc This pr does not need any document

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants