This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch fix-adapter-sink-publishing in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit a8588f62158e29b624f002dbc02c063b01c99f34 Author: Dominik Riemer <[email protected]> AuthorDate: Tue Nov 4 11:32:56 2025 +0100 fix: Avoid sending events twice in adapter sink --- .../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(
