[Refactor] Convert KafkaStore to EventStore
Currently we have hardcoded KafkaStore as a composite of StorageInterface along with a kafka producer,
However we wanna make this more generic by substituting KafkaProducer with a generic MessageInterface
The final structure of EventStore would look like
#[derive(Clone)]
pub struct EventStore<T: StorageInterface, E: MessagingInterface> {
event_producer: E,
storage: T,
}
This refactor could be done in 2 parts as follows
- Use
MessageInterfaceas a generic trait instead of fixedKafkaProducer - Remove
KafkaMessagetrait implementations and useMessageInterfaceinstead
Hey @lsampras! I would like to help with this issue. Can I work on this?
Hi @rishav-bose0, since this change is slightly spread out throughout the code base, I'd prefer if we connect on either slack or discord to formulate & plan the approach to solve this...
sure, I too had some doubts on the generic replacements. Let's connect on discord.
Hey! Is this still open?
Hey @speedhs thanks for the interest, unfortunately this issue is no longer relevant... Feel free to take a look at some of our other open issues