this.batchSizeSupplier = batchSizeSupplier;
this.threadCount = threadCount;
this.readThreadCount = readThreadCount;
this.followers = followers;
NamedThreadFactory threadFactory = new NamedThreadFactory(SCRUBBER_THREAD_PREFIX, true);
<BUG>this.readerExec = PTExecutors.newFixedThreadPool(readThreadCount, threadFactory);

this.exec = PTExecutors.newFixedThreadPool(threadCount, threadFactory);
</BUG>
}

this.batchSizeSupplier = batchSizeSupplier;
this.threadCount = threadCount;
this.readThreadCount = readThreadCount;
this.followers = followers;
NamedThreadFactory threadFactory = new NamedThreadFactory(SCRUBBER_THREAD_PREFIX, true);
this.readerExec = Tracers.wrap(PTExecutors.newFixedThreadPool(readThreadCount, threadFactory));
this.exec = Tracers.wrap(PTExecutors.newFixedThreadPool(threadCount, threadFactory));
}
