I haven’t found a way to specify that a consumer should read from the beginning, or from any other explicit offset, or that the offset should be “reset” in any way. The command-line shell scripts (which I believe simply wrap the Scala tools) have flags for this sort of thing. Is there any way to do this through the python library?
Thanks.
