We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent df86dfa commit 6a09b3eCopy full SHA for 6a09b3e
pulsar-function-go/pf/instance.go
@@ -471,7 +471,7 @@ func getIdleTimeout(timeoutMilliSecond time.Duration) time.Duration {
471
func (gi *goInstance) setupLogHandler() error {
472
if gi.context.instanceConf.funcDetails.GetLogTopic() != "" {
473
gi.context.logAppender = NewLogAppender(
474
- gi.client, //pulsar client
+ gi.client, //pulsar client
475
gi.context.instanceConf.funcDetails.GetLogTopic(), //log topic
476
getDefaultSubscriptionName(gi.context.instanceConf.funcDetails.Tenant, //fqn
477
gi.context.instanceConf.funcDetails.Namespace,
0 commit comments