KPOps generate breaks when source connector is defined in the middle of the pipeline

[raminqaf]

Whenever we define a source connector in the middle of the pipeline (without defining the from section), KPOps automatically adds the FromSection to the source connector, which leads to the following error:

NotImplementedError: Kafka source connector doesn't support FromSection

This is probably an error that will occur with a producer.

One way to solve this issue is not to generate the from section automatically if the type is ProducerApp or SourceConnector. Alternatively, we can ignore the from section and instead of an exception, log a warning.

[irux]

So for example

• producer
• source
• producer/app ?