Create new operator with new kafka consumer client to consume message from different kafka partition