Looking for feedback on if 2 new sinks would be accepted by the community.
1. InvokeHttpSink: that would make an http request per record, to insert or update a remote end point 2. DistributredMapCacheSink: to insert records into the cache map by a key given a record path
