mjsax commented on a change in pull request #10460:
URL: https://github.com/apache/kafka/pull/10460#discussion_r627845711
##########
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"
Review comment:
nit (formatting): might be easier to read if we move to new line:
```
log.info(
"Could not create topic {}. Topic is probably marked for deletion
(number of partitions is unknown).\n"
```
--
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
