> we want map to keep reading data from a min offset and roll over every 30 > mins . At 30th min we would again generate the offsets which would be used > for the next run.
Using the max offset would avoid deserializing the data. You could use timestamp too, but for that you would need to include a timestamp in your Kafka message and then deserialize data in the map task. Thanks, Neha
