projects
/
demos
/
kafka
/
deduplication
/ shortlog
commit
grep
author
committer
pickaxe
?
search:
re
summary
| shortlog |
log
|
commit
|
commitdiff
|
tree
first ⋅ prev ⋅ next
demos/kafka/deduplication
2024-05-05
Kai Moritz
Using names instead of numbers as key for the messages
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Added generated *.txt files to clean-up
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Added actuators and implemented an indicator that repor...
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Added an endpoint to query the watermarks by partition
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Moved the building of the topology into a static method
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Implemented an unit-test for the transformer
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Offsets are not needed by the test
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Implemented an integration-test for the transformer
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
Simplified example
commit
|
commitdiff
|
tree
|
snapshot
2024-05-05
Kai Moritz
A deduplicator, that assumes steadily increasing global...
commit
|
commitdiff
|
tree
|
snapshot