Building the Broker's Network Layer

Build a TCP server using net.Listener that accepts and manages multiple connections.

Implement concurrent connection handling using a goroutine per connection and sync.WaitGroup for graceful shutdown.

Design a simple binary protocol with message types for produce, consume, and acknowledge operations.

Implement length-prefixed binary message framing for reliable TCP communication.

Encode and decode protocol messages using binary serialization with encoding/binary.

Establish a connection to the TCP server and implement a function to send a single framed protocol message.

Implement a read loop in the TCP client to receive and decode framed messages from the server.

Compose the send and receive functions into a client that executes a full request-response cycle.