Merge pull request #13 from ericzhifengchen/main

fix flaky test testSubmitMessageWithCommitResponse

uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java

@@ -246,7 +246,7 @@ public void testSubmitMessageWithSameClusterShouldNotBeFiltered() throws Excepti
         dispatcherMessageArgumentCaptor.getValue().getItem().getGrpcMessage().getDispatchAttempt());
   }
 
-  @Test(timeout = 5000)
+  @Test(timeout = 10000)
   public void testSubmitMessageWithCommitResponse() throws Exception {
     processor.start();
     CompletableFuture<DispatcherResponse> dispatcherFuture = new CompletableFuture<>();