Ovidiu Gheorghioiu

Add Ruby implementation of Kafka's partition hasher (based on key). Test

3

that it matches results from Java. Not hooked up yet (future commits), but can already be used manually by a client. Use case is to pick the partition where one...

As it turns out, it's a simple matter of changing where the next fetch will be requested (a state variable). The method accepts the same special offsets as the constructor.

Heya, I have a need for seeking a consumer, i.e. the equivalent of reopening a consumer with the desired offset. Simply setting the @offset variable in the current implementation would...