title: How to conditionally publish an additional SSE web flux event after sending first 100 messages consumed from reactor kafka topic
body: <p>I am consuming data from a kafka topic using reactor-kafka library with spring webflux SSE streams. I need to return a special ServerSentEvent when all the messages from the topic are consumed i.e. maximum topic offset get equals to current offset consumed while subscribing from 0 offset. so that clients get to know that there are no more messages present at kafka topic.</p>
  <p>Is it possible to achieve something like this using web flux? i.e. if I say after every 100 elements consumed from any finite list of elements and sent over SSE stream as ServerSentEvent this SSE stream should get one more event as SeverSentEvent with comment &quot;consumed&quot;.</p>