Skip to content

[fix][fn] Go functions must retrieve consumers by non-particioned topic ID#3

Open
flowchartsman wants to merge 3 commits into
masterfrom
fix_response_partitioned_msg_topic
Open

[fix][fn] Go functions must retrieve consumers by non-particioned topic ID#3
flowchartsman wants to merge 3 commits into
masterfrom
fix_response_partitioned_msg_topic

Conversation

@flowchartsman

Copy link
Copy Markdown
Owner

Fixes apache#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: #3

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

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

2 participants