mjsax commented on a change in pull request #9997:
URL: https://github.com/apache/kafka/pull/9997#discussion_r568273206
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##########
@@ -111,13 +112,16 @@ public void initialize() {
final List<PartitionInfo> partitions;
try {
partitions = streamsProducer.partitionsFor(topic);
- } catch (final KafkaException e) {
- // TODO: KIP-572 need to handle `TimeoutException`
- // -> should we throw a `TaskCorruptedException` for this case
to reset the task and retry (including triggering `task.timeout.ms`) ?
+ } catch (final TimeoutException timeoutException) {
+ log.debug("Could not get partitions for topic {}, will retry",
topic);
Review comment:
INFO does not make sense I guess. So WARN it it.
----------------------------------------------------------------
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
