add label

Signed-off-by: Song Gao <[email protected]>
lf-edge · Feb 27, 2025 · d8786a2 · d8786a2
1 parent 5567c79
commit d8786a2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/extensions/sinks/kafka/ext/kafka.go b/extensions/sinks/kafka/ext/kafka.go
@@ -167,6 +167,8 @@ func (m *kafkaSink) buildKafkaWriter() error {
 
 func (m *kafkaSink) Open(ctx api.StreamContext) error {
 	ctx.GetLogger().Debug("Opening kafka sink")
+	m.writer.RuleID = ctx.GetRuleId()
+	m.writer.OpID = ctx.GetOpId()
 	return nil
 }