Skip to content

Instantly share code, notes, and snippets.

@miguno

miguno/foo.java

Last active September 27, 2019 22:46
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save miguno/746a3cbee14cea7ddcadcf0064021365 to your computer and use it in GitHub Desktop.
Save miguno/746a3cbee14cea7ddcadcf0064021365 to your computer and use it in GitHub Desktop.
Download ZIP
Read KTable / TABLE from beginning (not from 'now')
Raw
foo.java
StreamsBuilder#table("my-topic",
Consumed.with(AutoOffsetReset.EARLIEST));
Raw
foo.sql
SET 'auto.offset.reset'='earliest';
CREATE TABLE ...
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment