Hi, I'm an Apache Pulsar contributor, and I'm very interested in your project! I've wanted a GUI for building serverless flows involving Flink and Pulsar for a long time, and your project seems to be the perfect platform for that.
I noticed that you have support currently for Flink processors, and you have a Pulsar connector, but it doesn't appear that you have support for Pulsar function processors yet. My team has created a collection of generic Pulsar functions for performing common tasks, and it would be awesome if we could get StreamPipes to allow teams to use the UI to build flows with them. Examples of functions include things like JSON schema validation, sieves (dropping out columns), Pulsar message filters, and many others. What classes would be involved in adding support for Pulsar functions? We also have some topics involved in governance and automation for our functions, so I'd also like to write an interception layer to allow us to kick off those tasks when functions are created. If someone could please point out the code paths that I'd want to look at in StreamPipes, that would help a lot! Devin G. Bost
