Discussion question: This adds a second method to the gRPC interface. This isn't a pattern that exists today and so minor pattern deviation, but it does retain backwards compatibility. What is the design intention of numaflow team as to how to address breaking (or not breaking) existing APIs?
Sets up a new endpoint as part of streammapper that can take stream input. Meant to address part of https://github.com/numaproj/numaflow/issues/1564
Discussion question: This adds a second method to the gRPC interface. This isn't a pattern that exists today and so minor pattern deviation, but it does retain backwards compatibility. What is the design intention of numaflow team as to how to address breaking (or not breaking) existing APIs?