proxystore.stream.shims¶
Shim interfaces to common message brokers.
The Publisher and
Subscriber are
Protocols which define the publisher and subscriber
interfaces to a pub/sub-like message broker.
This sub-package provides a set of shim or adapter interfaces to
common pub/sub systems like Kafka, Redis, and ZeroMQ. Generally, these
shims are very lightweight and mostly serve to adapt the third-party
interface to match the Publisher and
Subscriber protocols expected
by the StreamProducer
and StreamConsumer.
Warning
Most of the provided shims have an external dependency that may not be installed by default with ProxyStore.