From 89919c391482b46340b43c7636095e9826a61063 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Fri, 20 Sep 2024 15:45:48 -0700 Subject: [PATCH] Clean up. --- processes/consumer/process.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/processes/consumer/process.go b/processes/consumer/process.go index b2bf96f73..2df7cabbf 100644 --- a/processes/consumer/process.go +++ b/processes/consumer/process.go @@ -39,7 +39,7 @@ func (p processArgs) process(ctx context.Context, cfg config.Config, inMemDB *mo topicConfig, isOk := p.TopicToConfigFormatMap.GetTopicFmt(p.Msg.Topic()) if !isOk { tags["what"] = "failed_topic_lookup" - return "", fmt.Errorf("failed to get topic name: %s", p.Msg.Topic()) + return "", fmt.Errorf("failed to get topic name: %q", p.Msg.Topic()) } tags["database"] = topicConfig.tc.Database @@ -65,7 +65,6 @@ func (p processArgs) process(ctx context.Context, cfg config.Config, inMemDB *mo } // Table name is only available after event has been cast tags["table"] = evt.Table - if topicConfig.tc.ShouldSkip(_event.Operation()) { // Check to see if we should skip first // This way, we can emit a specific tag to be more clear