return Utils.serializeRecordToJson(recordCtx,data).getBytes(); | return ByteBuffer.wrap(Utils.serializeRecordToJson(recordCtx,data).getBytes()); | Utils.serializeRecordToJson(recordCtx,data).getBytes() | ByteBuffer.wrap(Utils.serializeRecordToJson(recordCtx,data).getBytes()) | pulsar | 2a6d1950954e9d0b1ec33c7fc738ebbdab0a4b9e | org.apache.pulsar.io.kinesis.KinesisSink | | _1 | createKinesisMessage |
---|
_2 | createKinesisMessage |
---|
| v0 | Utils.serializeRecordToJson(recordCtx,data).getBytes() |
---|
| | v0 | Utils.serializeRecordToJson(recordCtx,data).getBytes() |
---|
| Returns | True |