A worker receives messages for a single topic for a single partition.

Processing the message set is delegated to the configured message handler (See Kaffe.MessageHandler). The result of handle_messages is sent back to the subscriber. Additionally, the message handler should inform the subscriber on what to do with the offsets after processing the message set.