fix: once again fix logic for always setting the offset header

telekom · Nov 26, 2024 · 7909875 · 7909875
1 parent 4a18e98
commit 7909875
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/main/java/de/telekom/horizon/pulsar/service/EventMessageSupplier.java b/src/main/java/de/telekom/horizon/pulsar/service/EventMessageSupplier.java
@@ -129,9 +129,7 @@ public EventMessageContext get() {
                         throw new SubscriberDoesNotMatchSubscriptionException(errorMessage);
                     }
 
-                    if (StringUtils.isNotEmpty(currentOffset)) {
-                        Optional.ofNullable(message.getHttpHeaders()).ifPresent(headers -> headers.put("x-pubsub-offset-id", new ArrayList<>(List.of(currentOffset))));
-                    }
+                    Optional.ofNullable(message.getHttpHeaders()).ifPresent(headers -> headers.put("x-pubsub-offset-id", new ArrayList<>(List.of(state.getUuid()))));
                 }
                 return new EventMessageContext(message, includeHttpHeaders, streamLimit, ignoreDeduplication, span, spanInScope);
             } catch (CouldNotPickMessageException | SubscriberDoesNotMatchSubscriptionException e) {