We need a message queue abstraction that provides a common interface for topic-based messaging, with a first…
We need a message queue abstraction that provides a common interface for topic-based messaging, with a first…: a task in LegoFlow-SWE (Harbor dataset). The implementation should be backed by Kafka, but the public API must only expose the MessageQueue trait and the KafkaImpl struct (plus the…
The task
The implementation should be backed by Kafka, but the public API must only expose the `MessageQueue` trait and the `KafkaImpl` struct (plus the associated `Message`, `ConsumeIterator`, and configuration construction). All topic operations (create, produce, consume, delete) must conform to the contract described above.
Part of Lego-X/LegoFlow-SWE.