zio-connect
zio-connect copied to clipboard
Sources, Sinks and Pipelines for channeling data
- [x] kafka-connector - [ ] kinesis-datastreams-connector
I still need to add tests. But l want us to discuss the design first.
Context - We want to add a versions of `get` that also return cas and a version of `replace` that uses cas. That way we can do smth like 'getWithCas...
`TestCassandraConnectorSpec` tests fail. I have reached the conclusion that `repo.get` somehow fails and nothing from there on is executed
PR for https://github.com/zio/zio-connect/issues/80
#Steps - [ ] Add a new project -- Example: https://github.com/zio/zio-connect/blob/2507925dcd9acf5cb1dbb5e004afef3982ad6807/build.sbt#L38 - [ ] Create the following directory structure zio.connect.firehose - [ ] Create the connector sealed trait FirehoseConnector case...
#Steps - [ ] Add a new project -- Example: https://github.com/zio/zio-connect/blob/2507925dcd9acf5cb1dbb5e004afef3982ad6807/build.sbt#L38 - [ ] Create the following directory structure zio.connect.ftp - [ ] Create the connector sealed trait FTPConnector case...
#Steps - [ ] Add a new project -- Example: https://github.com/zio/zio-connect/blob/2507925dcd9acf5cb1dbb5e004afef3982ad6807/build.sbt#L38 - [ ] Create the following directory structure zio.connect.jms - [ ] Create the connector sealed trait JMSConnector case...
The context is: " Does it manages inotify for directory watching? It's such a mess and jdk impl with its OVERFLOW is not helping, no more than not knowing when...