Skip to content

Instantly share code, notes, and snippets.

@miguno

miguno/foo.java

Last active September 27, 2019 22:46
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