This is an automated email from the ASF dual-hosted git repository. mjsax 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 5795675 MINOR:Replace duplicated code with common function in utils (#6819) 5795675 is described below commit 579567559915e750d305d51a10d9c6797b6eb2aa Author: Lifei Chen <lifei.c...@allseeingsecurity.com> AuthorDate: Fri May 31 07:46:41 2019 +0800 MINOR:Replace duplicated code with common function in utils (#6819) Reviewers: Ivan Yurchenko <iva...@aiven.io>, Matthias J. Sax <matth...@confluent.io> --- .../src/main/java/org/apache/kafka/common/utils/SystemTime.java | 7 +------ .../kafka/streams/processor/internals/InternalTopicManager.java | 7 +------ 2 files changed, 2 insertions(+), 12 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java b/clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java index 9ef096f..31919a2 100644 --- a/clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java +++ b/clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java @@ -38,12 +38,7 @@ public class SystemTime implements Time { @Override public void sleep(long ms) { - try { - Thread.sleep(ms); - } catch (InterruptedException e) { - // just wake up early - Thread.currentThread().interrupt(); - } + Utils.sleep(ms); } @Override diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java index f9fe042..3cb06f6 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java @@ -155,12 +155,7 @@ public class InternalTopicManager { if (!topicsNotReady.isEmpty()) { log.info("Topics {} can not be made ready with {} retries left", topicsNotReady, retries); - try { - Thread.sleep(retryBackOffMs); - } catch (final InterruptedException e) { - // this is okay, we just wake up early - Thread.currentThread().interrupt(); - } + Utils.sleep(retryBackOffMs); remainingRetries--; }