instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java [316:328]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    withException(
        logger,
        scope,
        tracer,
        new ThrowingSupplier<Void, E>() {
          @Override
          public Void get() throws E {
            runnable.run();
            return null;
          }
        },
        name,
        tags);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java [418:430]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      withException(
          logger,
          scope,
          tracer,
          new ThrowingSupplier<Void, E>() {
            @Override
            public Void get() throws E {
              runnable.run();
              return null;
            }
          },
          name,
          tags);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -