I propose "Transactional Multiplex Sink" which uses single channel to fanout data stream to different receivers in one transaction. It is expected to greatly reduce the resource usage.
Primary LanguageJavaApache License 2.0Apache-2.0