diff --git a/.DS_Store b/.DS_Store new file mode 100644 index 00000000..102ecc34 Binary files /dev/null and b/.DS_Store differ diff --git a/roadmap.md b/roadmap.md index c82f024d..92a04f3c 100644 --- a/roadmap.md +++ b/roadmap.md @@ -1,6 +1,5 @@ # Roadmap Feature -- [X] Support CSFLE , DataQuality Rules .. - [ ] Dead letter queue mecanism - [ ] Reafactor External Call with similar behavior like ParrallelConsumer + a real async approach - [ ] Auto scaling consumption (inspired KEDA) @@ -13,4 +12,8 @@ - [ ] Versioned State Store - [ ] https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join - [ ] KIP-424 : Allow suppression of intermediate events based on wall clock time -- [ ] Extensions Streamiz \ No newline at end of file +- [ ] Extensions Streamiz +- [ ] At-most-once processing guarantee +- [ ] Support “broadcast” pattern +- [ ] Replace repartition topics with network shuffles +- [ ] Cross Cluster \ No newline at end of file