diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java index f71b19a8c..9e043c9e0 100644 --- a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java +++ b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java @@ -141,7 +141,9 @@ private void observeSyncStream() throws InterruptedException { metadataResponse = localStub.getMetadata(metadataRequest.build()); } catch (Exception metaEx) { - log.error("Metadata exception: {}, cancelling stream", metaEx.getMessage(), metaEx); + // cancel the stream if the getMetadata fails + // we can keep this log quiet since the stream is cancelled/restarted with this exception + log.debug("Metadata exception: {}, cancelling stream", metaEx.getMessage(), metaEx); context.cancel(metaEx); } }