Skip to content

Commit

Permalink
fix: find bugs issue in KafkaTopicClientImpl (#3268)
Browse files Browse the repository at this point in the history
  • Loading branch information
big-andy-coates authored Aug 28, 2019
1 parent ba1f613 commit 70e880f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -102,10 +102,10 @@ public void createTopic(
newTopic.configs(toStringConfigs(configs));

try {
LOG.info(String.format("Creating topic '{}' %s",
LOG.info("Creating topic '{}' {}",
topic,
(createOptions.shouldValidateOnly()) ? "(ONLY VALIDATE)" : ""
));
);

ExecutorUtil.executeWithRetries(
() -> adminClient.createTopics(
Expand Down

0 comments on commit 70e880f

Please sign in to comment.