search

uw-labs / proximo

Interoperable GRPC based publish/subscribe
GNU Lesser General Public License v3.0
41 stars 16 forks source link

Offset #54

Closed SpeedyCoder closed 5 years ago

SpeedyCoder commented 5 years ago

I added offset implementation for NATS and Kafka. I also added modules as the offset stuff is not merged yet in substrate (these PRs are codependent 😅). Again, the function for translating proximo offset to substrate one can be probably abstracted, but that should only be done after cleaning it up in substrate...

SpeedyCoder commented 5 years ago

Going split this to smaller PRs.