From 0e356cbfaf68b140ca3122a6a351b6d5dfdd5361 Mon Sep 17 00:00:00 2001 From: scwlkq Date: Tue, 20 Feb 2024 17:31:36 +0800 Subject: [PATCH] delete todo --- .../org/apache/eventmesh/openconnect/util/CloudEventUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java index 5d4a77ff78..3fb5ea2b74 100644 --- a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java +++ b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java @@ -67,7 +67,7 @@ public static CloudEvent convertRecordToEvent(ConnectRecord connectRecord) { public static ConnectRecord convertEventToRecord(CloudEvent event) { byte[] body = Objects.requireNonNull(event.getData()).toBytes(); LogUtil.info(log, "handle receive events {}", () -> new String(event.getData().toBytes(), Constants.DEFAULT_CHARSET)); - // todo: recordPartition & recordOffset + ConnectRecord connectRecord = new ConnectRecord(null, null, System.currentTimeMillis(), body); for (String extensionName : event.getExtensionNames()) { connectRecord.addExtension(extensionName, Objects.requireNonNull(event.getExtension(extensionName)).toString());