code: private static ScheduledThreadPoolExecutor buildWriterMetricsUpdater() {
      return new ScheduledThreadPoolExecutor(1,
          ExecutorsUtils.newThreadFactory(Optional.of(log), Optional.of("WriterMetricsUpdater-%d")));
    }
docs: Build a {@link ScheduledThreadPoolExecutor} that updates record-level and byte-level metrics.