(streampipes) branch dev updated: fix: Avoid sending events twice in adapter sink (#3892)

[riemer]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 2661dd08f1 fix: Avoid sending events twice in adapter sink (#3892)
2661dd08f1 is described below

commit 2661dd08f19eddea6e1418058ab43bf13493d78e
Author: Dominik Riemer <dominik.rie...@gmail.com>
AuthorDate: Tue Nov 4 12:40:41 2025 +0100

    fix: Avoid sending events twice in adapter sink (#3892)
---
 .../connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java  | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java
 
b/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java
index 59c1d46ef0..e78338a7b8 100644
--- 
a/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java
+++ 
b/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java
@@ -65,7 +65,6 @@ public class SendToBrokerAdapterSink implements 
IAdapterPipelineElement {
   public Map<String, Object> process(Map<String, Object> event) {
     try {
       if (event != null) {
-        sendToBroker(dataFormatDefinition.fromMap(event));
         byte[] data = dataFormatDefinition.fromMap(event);
         sendToBroker(data);
         SpMonitoringManager.INSTANCE.increaseOutCounter(