Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5412

Using connect-console-sink/source.properties raises an exception related to "file" property not found

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.2.1
    • Fix Version/s: 1.0.0
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      With the latest 0.11.1.0-SNAPSHOT it happens that the Kafka Connect example using connect-console-sink/source.properties doesn't work anymore because the needed "file" property isn't found. This is because the underlying used FileStreamSink/Source connector and task has defined a ConfigDef with "file" as mandatory parameter. In the case of console example we want to have file=null so that stdin and stdout are used.

      One possible solution and workaround is set "file=" inside the provided connect-console-sink/source.properties. The other one could be modify the FileStreamSink/Source source code in order to remove the "file" definition from the ConfigDef.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                ppatierno Paolo Patierno
                Reporter:
                ppatierno Paolo Patierno
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: