Skip to content

Commit

Permalink
delete todo
Browse files Browse the repository at this point in the history
  • Loading branch information
scwlkq committed Feb 20, 2024
1 parent 7994cb1 commit 0e356cb
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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());
Expand Down

0 comments on commit 0e356cb

Please sign in to comment.