Skip to content

Commit

Permalink
GH-3024: Add logging for exceptions in KafkaTopicProvisioner
Browse files Browse the repository at this point in the history
Related to #3024
  • Loading branch information
sobychacko committed Oct 24, 2024
1 parent 9888a08 commit 4dfd9c1
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2014-2023 the original author or authors.
* Copyright 2014-2024 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -668,6 +668,7 @@ public Collection<PartitionInfo> getPartitionsForTopic(final int partitionCount,
partitions = callable.call();
}
catch (Exception ex) {
logger.warn("Error occurred while calculating partitions for topic: " + topicName, ex);
// The above call can potentially throw exceptions such as timeout. If
// we can determine
// that the exception was due to an unknown topic on the broker, just
Expand Down

0 comments on commit 4dfd9c1

Please sign in to comment.