@Test
public void setAndThenGetValue() throws Exception {

  String key = UUID.randomUUID().toString();
  try (KafkaStore<String, String> store = new KafkaStore<>(CLUSTER.bootstrapServers(), SERIALIZER, TOPIC)) {
    store.put(key, "test-value");
    String value = store.get(key);
    assertThat(value, is("test-value"));
  }
}