Changeset 443 in code for trunk/upstream.go

Timestamp:

Jan 10, 2021, 9:48:08 PM (4 years ago)

Author:

hubert

Message:

Don't forward batch tags

We don't want to have the batch tag when calling uc.produce, otherwise
downstream will end up with junk batch ids.

File:

• trunk/upstream.go (modified) (1 diff)

trunk/upstream.go

@@ -366 +366 @@
                         label = msgBatch.Label
                 }
+                delete(msg.Tags, "batch")
         }