Implementing Consumers and Group Coordination

Implement the core logic to read a sequence of messages from a partition's log given a starting offset.

Integrate the partition-reading logic into the TCP server to handle consumer requests.

Use the 'select' statement with timeouts to multiplex across channel operations without blocking.

Design the data structures and state management for consumer groups, including membership and offset tracking.

Implement the consumer group join and leave protocol for dynamic membership.

Implement a rebalancing algorithm to assign partitions to active consumers within a group.