Commit 2ef924cd authored by Shikhar Bhushan's avatar Shikhar Bhushan
Browse files

use thread factor to make farmer thread

parent 7996bf16

src/main/java/io/confluent/connect/elasticsearch/bulk/BulkProcessor.java

+1 −1
Original line number Diff line number Diff line
@@ -89,7 +89,7 @@ public class BulkProcessor<R, B> { 
    unsentRecords = new ArrayDeque<>(maxBufferedRecords);



    final ThreadFactory threadFactory = makeThreadFactory();

    farmer = new Thread(farmerTask());

    farmer = threadFactory.newThread(farmerTask());

    executor = Executors.newFixedThreadPool(maxInFlightRequests, threadFactory);

  }