diff --git a/micronaut/pom.xml b/micronaut/pom.xml
index 3c41e38..1855df7 100644
--- a/micronaut/pom.xml
+++ b/micronaut/pom.xml
@@ -4,7 +4,7 @@
com.reforge
sdk-parent
- 1.0.2
+ 1.0.3
sdk-micronaut-extension
diff --git a/pom.xml b/pom.xml
index 7553b46..9f1b014 100644
--- a/pom.xml
+++ b/pom.xml
@@ -11,7 +11,7 @@
com.reforge
sdk-parent
- 1.0.2
+ 1.0.3
pom
Reforge SDK Parent POM
Parent POM for Reforge SDK modules providing feature flags, configuration management, and A/B testing capabilities
diff --git a/sdk/pom.xml b/sdk/pom.xml
index cb3b7df..d3889c4 100644
--- a/sdk/pom.xml
+++ b/sdk/pom.xml
@@ -4,7 +4,7 @@
com.reforge
sdk-parent
- 1.0.2
+ 1.0.3
sdk
diff --git a/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java b/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java
index bcbff6b..3f912a1 100644
--- a/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java
+++ b/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java
@@ -109,9 +109,8 @@ public void onSubscribe(Flow.Subscription subscription) {
public void onNext(Event item) {
if (item instanceof CommentEvent) {
CommentEvent commentEvent = (CommentEvent) item;
- LOG.info("Received comment event: {}", commentEvent);
- }
- if (item instanceof DataEvent) {
+ LOG.debug("Received comment event: {}", commentEvent);
+ } else if (item instanceof DataEvent) {
DataEvent dataEvent = (DataEvent) item;
try {
hasReceivedData.set(true);
@@ -142,7 +141,6 @@ public void onNext(Event item) {
@Override
public void onError(Throwable throwable) {
- LOG.info("Unexpected error encountered", throwable);
if (Optional.ofNullable(throwable.getMessage()).orElse("").contains("GOAWAY")) {
LOG.debug("Got GOAWAY on SSE config stream, will restart connection.");
} else {
@@ -154,7 +152,7 @@ public void onError(Throwable throwable) {
@Override
public void onComplete() {
// this is called even on auth failure
- LOG.info("Unexpected stream completion");
+ LOG.debug("Unexpected stream completion");
restartHandler.accept(getHasReceivedData());
}