kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: Bump admin client retries for creating repartition topics (#6063)
Date Sat, 22 Dec 2018 06:44:04 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 53eb8df  MINOR: Bump admin client retries for creating repartition topics (#6063)
53eb8df is described below

commit 53eb8df344c376ed651db83a084f962083df8a6d
Author: Bill Bejeck <bbejeck@gmail.com>
AuthorDate: Sat Dec 22 01:43:55 2018 -0500

    MINOR: Bump admin client retries for creating repartition topics (#6063)
    
    The topology optimization test was getting intermittent failures because of failures to
create repartition topics on startup. This PR Increased admin client retries
    
    I kicked off the system test with 25 repeats, all passed http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2018-12-21--001.1545436859--bbejeck--MINOR_flaky_optimization_test_create_repartition_fails--6cd55e2/report.html
    
    Reviewers: Guozhang Wang <wangguoz@gmail.com>
---
 .../test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java
b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java
index 6bde92f..13c1d7b 100644
--- a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java
@@ -17,6 +17,7 @@
 
 package org.apache.kafka.streams.tests;
 
+import org.apache.kafka.clients.admin.AdminClientConfig;
 import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.streams.KafkaStreams;
@@ -111,6 +112,7 @@ public class StreamsOptimizedTest {
         config.setProperty(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, "0");
         config.setProperty(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
         config.setProperty(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
+        config.setProperty(StreamsConfig.adminClientPrefix(AdminClientConfig.RETRIES_CONFIG),
"100");
 
 
         config.putAll(streamsProperties);


Mime
View raw message