When doing filtering based on offset and ROWTIME, we need a ksqldb config auto.offset.reset to earliest.

https://developer.confluent.io/tutorials/filter-a-stream-of-events/ksql.html

To do

• Fix and deploy to dev.
• Test for offset and ROWTIME filtering from dev env
• Deploy to prod
• Run integration test
• Test for offset and ROWTIME filtering from prod env
• Send a documentation to customer about how to use the parallel consumption/ seamless restart
• Update swagger docs for realtime