[server][da-vinci-client] Return proper error code from getTopicParti…

…tionEndOffSet
majisourav99 · Feb 25, 2025 · c720b47 · c720b47
1 parent 6085419
commit c720b47
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java b/...da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java
@@ -2409,12 +2409,9 @@ protected long getTopicPartitionEndOffSet(String kafkaUrl, PubSubTopic pubSubTop
           Duration.ofMillis(500),
           Duration.ofSeconds(5),
           Arrays.asList(PubSubTopicDoesNotExistException.class, PubSubOpTimeoutException.class, VeniceException.class));
-    } catch (PubSubTopicDoesNotExistException | PubSubOpTimeoutException e) {
+    } catch (Exception e) {
       LOGGER.error("Failed to get end offset for topic-partition: {} even after 10 retries", topicPartition, e);
       return StatsErrorCode.LAG_MEASUREMENT_FAILURE.code;
-    } catch (Exception e) {
-      LOGGER.error("Could not find latest offset for {} even after 10 retries", pubSubTopic.getName());
-      return -1;
     }
   }