search

tarungka / wire

Wire is a distributed open source stream processing framework with powerful stream and batch-processing capabilities.[UNDER DEVELOPEMENT]
GNU General Public License v3.0
2 stars 1 forks source link

TEST: Test if the source and sink both produce and read data chronologically #33

Open tarungka opened 1 month ago

tarungka commented 1 month ago

Update #32 to use sunchronous sources and sinks, i.e ProduceSync and while consuming, ensure the chronology of the messages are maintained.