class ThreadLocalDeserializer implements Deserializer<T> {

  @Override
  public T deserialize(final String topicName, final byte[] record) {
    return deserializer.get().deserialize(topicName, record);
  }

  public  ThreadLocalDeserializer(final Supplier<Deserializer<T>> initialValueSupplier);

}