events->points in Ensemble
using sub workers for sending  batches to kafka.