search

libp2p / go-libp2p-pubsub

The PubSub implementation for go-libp2p
https://github.com/libp2p/specs/tree/master/pubsub
Other
319 stars 185 forks source link

feature wanted: work like message queue such as kafka #400

Closed bitcard closed 3 years ago

bitcard commented 3 years ago

pubsub not support offline message at present, sub node go die for a while, and then go live, they will lost some messages. so it's necessary cache message for a perid of time, such as 24 hour. when node go online, they can consume the message, further more, add a offset to marking the consumption position.

vyzo commented 3 years ago

Sorry, but that's out of scope for the library.

bitcard commented 3 years ago

Sorry, but that's out of scope for the library.

ok, thank you for the reply, is there a similar solution or other demo code?

vyzo commented 3 years ago

check go-libp2p-pubsub-router, it's using last message persistence and a side protocol for synchronization.

bitcard commented 3 years ago

check go-libp2p-pubsub-router, it's using last message persistence and a side protocol for synchronization.

thank you.