Refactor pipeline filter and add to public API

bakdata / kpops

Deploy Kafka pipelines to Kubernetes

https://bakdata.github.io/kpops

MIT License

12 stars 1 forks source link

Refactor pipeline filter and add to public API #405

Closed disrupted closed 7 months ago

disrupted commented 8 months ago

Closes #110

Output of kpops generate is now actually used for the other operations new filter method as part of public Pipeline API, takes any custom filter function as predicate