Skip to content

[fix][fn] Go functions must retrieve consumers by non-partitioned topic ID#20413

Merged
Technoboy- merged 1 commit into
apache:masterfrom
flowchartsman:fix_response_partitioned_msg_topic
May 31, 2023
Merged

[fix][fn] Go functions must retrieve consumers by non-partitioned topic ID#20413
Technoboy- merged 1 commit into
apache:masterfrom
flowchartsman:fix_response_partitioned_msg_topic

Conversation

@flowchartsman

Copy link
Copy Markdown
Contributor

Fixes #19367

Modifications

Retrieve consumers from the index based off of non-partitioned topic name.

Verifying this change

  • Make sure that the change passes the CI checks.

This change is a trivial rework / code cleanup without any test coverage.

Note: there is no e2e for Go pulsar functions. Verifying this change is a matter of not having panics when using pulsar functions with partitioned topics.

Does this pull request potentially affect one of the following parts:

If the box was checked, please highlight the changes

  • Dependencies (add or upgrade a dependency)
  • The public API
  • The schema
  • The default values of configurations
  • The threading model
  • The binary protocol
  • The REST endpoints
  • The admin CLI options
  • The metrics
  • Anything that affects deployment

Documentation

  • doc
  • doc-required
  • doc-not-needed
  • doc-complete

Matching PR in forked repository

PR in forked repository: flowchartsman#3

@github-actions github-actions Bot added the doc-not-needed Your PR changes do not impact docs label May 27, 2023
@flowchartsman

flowchartsman commented May 27, 2023

Copy link
Copy Markdown
Contributor Author

This PR supplants #19372, which, in addition to targeting the master branch, has been sitting around long enough to become pretty out of date. Since this is a fairly nasty bug, I'm submitting this variant now to facilitate a faster merge. CC: @freeznet @wolfstudy for review. and @pocockn, who brought it to my attention again in Slack

@Technoboy- Technoboy- merged commit fb1b46e into apache:master May 31, 2023
Technoboy- pushed a commit that referenced this pull request May 31, 2023
…ic ID (#20413)

Co-authored-by: Andy Walker <andy@andy.dev>
Technoboy- pushed a commit that referenced this pull request May 31, 2023
…ic ID (#20413)

Co-authored-by: Andy Walker <andy@andy.dev>
michaeljmarshall pushed a commit that referenced this pull request Jun 6, 2023
…ic ID (#20413)

Co-authored-by: Andy Walker <andy@andy.dev>
(cherry picked from commit fb1b46e)
michaeljmarshall pushed a commit to datastax/pulsar that referenced this pull request Jun 6, 2023
…ic ID (apache#20413)

Co-authored-by: Andy Walker <andy@andy.dev>
(cherry picked from commit fb1b46e)
@Technoboy- Technoboy- changed the title [fix][fn] Go functions must retrieve consumers by non-particioned topic ID [fix][fn] Go functions must retrieve consumers by non-partitioned topic ID Jul 18, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Bug] [pulsar-function-go] function process ackInputMessage error

6 participants