nlu90 opened a new issue #11307:
URL: https://github.com/apache/pulsar/issues/11307
**Describe the bug**
When `SubName` is set for go functions:
```
pulsarctl.FuncConfig{
Tenant: common.TenantFlows,
Namespace: common.NamespaceScopes,
Name: agent.UUID,
Inputs: []string{
common.TopicName(common.TenantFlows,
common.NamespaceScopes, agent.Scope),
},
SubName: agent.UUID,
Output:
common.FlowsTopic(common.NamespaceAgentResults, agent.UUID),
LogTopic:
common.FlowsTopic(common.NamespaceAgentLogs, agent.UUID),
Parallelism: 1,
ProcessingGuarantees: "AT_LEAST_ONCE",
AutoAck: true,
RetainOrdering: true,
Runtime: "GO",
CleanupSubscription: true,
UserConfig: map[string]interface{}{"config":
userConfigString},
}
```
The actual subscription name is not correct: (it's using the default
`tenant/namespace/function_name` instead of the `subName`)
```
❯ pulsarctl subscriptions list persistent://flows/scopes/test
+-------------------------------------+
| SUBSCRIPTIONS |
+-------------------------------------+
| flows/scopes/6TmmWogtui4MUnzmgPMgyW |
+-------------------------------------+
```
**To Reproduce**
Steps to reproduce the behavior:
As described above
**Expected behavior**
Once the `subName` is set for go functions, the go instance runtime should
use the `subName` instead of the default `tenant/namespace/func_name` to
consume from pulsar cluster.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
