Skip to content

Commit b45d46e

Browse files
authored
fix: sink topic resolver (#3650)
1 parent 4f53fab commit b45d46e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

app/common/openmeter_sinkworker.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ func NewSink(
152152
sinkStorage sink.Storage,
153153
deduplicator dedupe.Deduplicator,
154154
meterService meter.Service,
155-
topicResolver *topicresolver.NamespacedTopicResolver,
155+
topicResolver topicresolver.Resolver,
156156
flushHandler flushhandler.FlushEventHandler,
157157
) (*sink.Sink, func(), error) {
158158
s, err := sink.NewSink(sink.SinkConfig{

0 commit comments

Comments
 (0)