utility to enable flexible ETL scenarios, supports golang plug-in for built-in consumer|transformer|producer options