-record(broker, {
    adapter :: lightspeed@pubsub:adapter(),
    topics_rev :: list(lightspeed@pubsub:topic_subscribers())
}).