Runs Kafka consumer and producer for the sample Spring Boot WEB app. Levarages Kafka Processor API to perform windowed de-duplication of feed. Models situation when clients do send data directly to our public API. Say, from mobile apps. Thus handling failures gracefully using retries, message re-delivery, locking, and two-phase commits is not an option.
-
Notifications
You must be signed in to change notification settings - Fork 0
kioria/feed-analyzer
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
Record de-duplicator using Kafka Spring Boot and Kafka Streams
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published