Commit 08cdbb46 authored by Liquan Pei's avatar Liquan Pei
Browse files

Increase flush timeout to 30000ms

parent 2252e1f0

src/test/java/io/confluent/connect/elasticsearch/BulkProcessorTest.java

+1 −1
Original line number Diff line number Diff line
@@ -43,7 +43,7 @@ public class BulkProcessorTest { 
  private final String type = "connect";

  private final String topic = "topic";

  private final int partition = 0;

  private final long flushTimeoutMs = 20000;

  private final long flushTimeoutMs = 30000;

  private final long lingerMs = 2000;

  private final int maxRetry = 5;

  private final long retryBackoffMs = 3000;