From a1baf6967ce1401b37bfab6e44cb95531138d304 Mon Sep 17 00:00:00 2001 From: Will Russell Date: Mon, 8 Jul 2024 14:35:57 +0100 Subject: [PATCH] fix: produce example --- src/main/java/io/kestra/plugin/kafka/Produce.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/java/io/kestra/plugin/kafka/Produce.java b/src/main/java/io/kestra/plugin/kafka/Produce.java index 2f81470..57fe91d 100644 --- a/src/main/java/io/kestra/plugin/kafka/Produce.java +++ b/src/main/java/io/kestra/plugin/kafka/Produce.java @@ -62,14 +62,15 @@ "id: send_message_to_kafka", "namespace: company.team", "inputs:", - " - type: FILE", - " id: file", + " - id: file", + " type: FILE", " description: A CSV file with columns: id, username, tweet, and timestamp.", "", "tasks:", " - id: csv_to_ion", " type: io.kestra.plugin.serdes.csv.CsvToIon", " from: \"{{ inputs.file }}\"", + "", " - id: ion_to_avro_schema", " type: io.kestra.plugin.scripts.nashorn.FileTransform", " from: \"{{ outputs.csvReader.uri }}\"", @@ -86,9 +87,10 @@ " }", " };", " row = result", + "", " - id: avro_to_kafka", " type: io.kestra.plugin.kafka.Produce", - " from: \"{{ outputs.fileTransform.uri }}\"", + " from: \"{{ outputs.ion_to_avro_schema.uri }}\"", " keySerializer: STRING", " properties:", " bootstrap.servers: localhost:9092",