adding streaming bulk for elastisearch sink