Skip to content

Instantly share code, notes, and snippets.

@softwaredoug

softwaredoug/TimestampPolicy.java

Created November 11, 2020 15:32
Show Gist options
  • Save softwaredoug/fd0086639d951bc6b4f3cfde0e576526 to your computer and use it in GitHub Desktop.
Save softwaredoug/fd0086639d951bc6b4f3cfde0e576526 to your computer and use it in GitHub Desktop.
Download ZIP
timestamp policy for Kafka
Raw
TimestampPolicy.java
new CustomTimestampPolicyWithLimitedDelay<Long, SearchQueryEvent>(
new GetSearchQueryTimestampFunction(),
Duration.standardMinutes(5),
previousWatermark
);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment