[FIX] Handle initial parameters status in KafkaSinkWithEditor properly (

#1967)
TouK · Jul 28, 2021 · 501f381 · 501f381
1 parent 5bb517f
commit 501f381
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/.../src/main/scala/pl/touk/nussknacker/engine/avro/sink/KafkaAvroSinkFactoryWithEditor.scala b/.../src/main/scala/pl/touk/nussknacker/engine/avro/sink/KafkaAvroSinkFactoryWithEditor.scala
@@ -56,6 +56,12 @@ class KafkaAvroSinkFactoryWithEditor(val schemaRegistryProvider: SchemaRegistryP
           NextParameters(valueParam.toParameters, state = Some(state))
         }
       }.valueOr(e => FinalResults(context, e.toList))
+    case TransformationStep
+      (
+        (`topicParamName`, _) ::
+        (SchemaVersionParamName, _) ::
+        (SinkKeyParamName, _) :: Nil, state
+      ) => FinalResults(context, Nil, state)
   }
 
   protected def finalParamStep(context: ValidationContext)(implicit nodeId: NodeId): NodeTransformationDefinition = {