@Test
public void testKeyPartitionIsStable() {

    int partition = partitioner.partition("test",  null, keyBytes, null, null, cluster);
    assertEquals("Same key should yield same partition", partition, partitioner.partition("test", null, keyBytes, null, null, cluster));
}