sea-streamer
sea-streamer copied to clipboard
SeaQL
🌊 A real-time stream processing toolkit for Rust
The configuration of latest Kafka might have been changed which cause CI [failed to run](https://github.com/SeaQL/sea-streamer/actions/runs/4806541676/jobs/8554717666#step:5:230). We should investigate it and update the Docker script accordingly.
## Motivation Since the message is behind a lifetime, it is currently not possible to return `impl Stream` from a function using consumer stream. The following cannot be compiled (_cannot...
File streamer is currently not compatible with Windows since it's using a specific use statement : `std::os::unix::` in `src/file.rs`. Can we make it windows compatible? Thanks for this awesome library...
## PR Info Added `From` and `FromIterator` for `StreamerUri`. - Closes - Fix #26 ## New Features - [x] `impl From for StreamerUri` ```rs let url: Url = "proto://sea-ql.org:1234".parse().unwrap(); let...
## Motivation Currently we cannot convert a `Url` into a `StreamerUri` unless we transform it back to a `String`. ## Proposed Solutions ```rs impl From for StreamerUri { fn from(value:...