[core] use Taskid for kafka task events instead of Environmentid

AliceO2Group · Mar 4, 2025 · 0cffa06 · 0cffa06
1 parent 3a5ee34
commit 0cffa06
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/common/event/writer.go b/common/event/writer.go
@@ -124,7 +124,10 @@ func (w *KafkaWriter) WriteEventWithTimestamp(e interface{}, timestamp time.Time
 				Payload:       &pb.Event_FrameworkEvent{FrameworkEvent: e},
 			}
 		case *pb.Ev_TaskEvent:
-			key = extractAndConvertEnvID(e)
+			key = []byte(e.Taskid)
+			if len(key) == 0 {
+				key = nil
+			}
 			wrappedEvent = &pb.Event{
 				Timestamp:     timestamp.UnixMilli(),
 				TimestampNano: timestamp.UnixNano(),