From b96a4d6d68a2eeef54778d332ffc475900c9e4b4 Mon Sep 17 00:00:00 2001 From: Brett Date: Wed, 11 Sep 2024 15:43:04 +1000 Subject: [PATCH] custom topics --- datastore/googlepubsub/publisher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datastore/googlepubsub/publisher.go b/datastore/googlepubsub/publisher.go index 45365ab..9c7365f 100644 --- a/datastore/googlepubsub/publisher.go +++ b/datastore/googlepubsub/publisher.go @@ -83,7 +83,7 @@ func NewProducer(ctx context.Context, prometheusEnabled bool, projectID string, func (p *Producer) Produce(entry *telemetry.Record) { ctx := context.Background() - topicName := telemetry.BuildTopicName(p.namespace, entry.TxType) + topicName := p.namespace logInfo := logrus.LogInfo{"topic_name": topicName, "txid": entry.Txid} pubsubTopic, err := p.createTopicIfNotExists(ctx, topicName)