Merge branch '11.1.x' into 12.0.x by sp-gupta

Author: ConfluentSemaphore

src/test/java/io/confluent/connect/elasticsearch/integration/ElasticsearchConnectorKerberosWithSslIT.java

@@ -11,6 +11,7 @@
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
+import org.junit.Ignore;
 
 @Category(IntegrationTest.class)
 public class ElasticsearchConnectorKerberosWithSslIT extends ElasticsearchConnectorKerberosIT{
@@ -33,6 +34,7 @@ public void testKerberos() {
     helperClient = null;
   }
 
+  @Ignore("flaky")
   @Test
   public void testKerberosWithSsl() throws Exception {
     // Use IP address here because that's what the certificates allow

src/test/java/io/confluent/connect/elasticsearch/integration/ElasticsearchConnectorNetworkIT.java

@@ -14,6 +14,7 @@
 import org.junit.Before;
 import org.junit.Rule;
 import org.junit.Test;
+import org.junit.Ignore;
 import org.junit.experimental.categories.Category;
 
 import java.time.Duration;
@@ -150,6 +151,7 @@ public void testConcurrentRequests() throws Exception {
     await().untilAsserted(() -> assertThat(blockingTransformer.requestCount()).isEqualTo(10));
   }
 
+  @Ignore("flaky")
   @Test
   public void testReadTimeout() throws Exception {
     wireMockRule.stubFor(post(urlPathEqualTo("/_bulk"))