mjsax commented on a change in pull request #10460:
URL: https://github.com/apache/kafka/pull/10460#discussion_r627843926
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##########
@@ -649,19 +434,38 @@ private void processCreateTopicResults(final
CreateTopicsResult createTopicsResu
final Throwable cause = executionException.getCause();
if (cause instanceof TopicExistsException) {
lastErrorsSeenForTopic.put(topicName, cause);
- log.info("Internal topic {} already exists. Topic
is probably marked for deletion. " +
- "Will retry to create this topic later (to let
broker complete async delete operation first)",
- topicName);
+ log.info("Could not create topic {}. Topic is
probably marked for deletion (number of partitions is unknown).\n"
+ + "Will retry to create this topic in {}
ms (to let broker finish async delete operation first).\n"
+ + "Error message was: {}",
+ topicName, retryBackOffMs,
Review comment:
nit: one parameter per line -> move `retryBackOffMs` to its own line
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
