fix: produce example

kestra-io · Jul 8, 2024 · a1baf69 · a1baf69
1 parent 25bae41
commit a1baf69
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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",