support consumer end-of-batch notification
support event batching