Today we can change the position of a consumer to:
- the end of the stream
- after the appended date when using Kafka
- after a give watermark date when using computation Record
- to the beginning of the stream
but sometimes we want to use a known offset (like one reported in an error message).
Also, stream.sh position -
after-watermark needs to support the -codec option to be able to work with avro record.