Creating a simple Message Bus: Episode 3

I's been a while since the last post, hey! Let's waste no time and dive straight in. This is the one everything has been building toward. We have a producer that sends messages to the broker. We have a broker that stores them in topic queues. All that's missing is the consumer — the thing that actually reads those messages. Let's build it. The Consumer // internal/consumer/consumer.go type Consumer struct { host string port string topic string } Simple. It