bakdata / kpops

Deploy Kafka pipelines to Kubernetes
https://bakdata.github.io/kpops
MIT License
12 stars 1 forks source link

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

Open raminqaf opened 8 months ago

raminqaf commented 8 months ago

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 commented 7 months ago

So for example