refactor

goto · Sep 20, 2024 · a02064e · a02064e
1 parent 3c6bbc1
commit a02064e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/modules/flink/driver_output.go b/modules/flink/driver_output.go
@@ -32,8 +32,7 @@ func (fd *flinkDriver) Output(ctx context.Context, exr module.ExpandedResource)
 	output.KubeCluster = kubeOut
 	output.Influx = conf.Influx
 	output.KubeNamespace = conf.KubeNamespace
-	output.Kafka.SinkKafkaStream = conf.Kafka.SinkKafkaStream
-	output.Kafka.SinkKafkaBrokers = conf.Kafka.SinkKafkaBrokers
+	output.Kafka = conf.Kafka
 
 	return modules.MustJSON(output), nil
 }