class ThreadLocalSerializer implements Serializer<T> {

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

  public  ThreadLocalSerializer(final Supplier<Serializer<T>> initialValueSupplier);

}