rdhabalia opened a new pull request #2079: Kinesis sink publish full json message URL: https://github.com/apache/incubator-pulsar/pull/2079 ### Motivation with #2024, Pulsar message contains `EncryptionContext` which can be used by application to decrypt encrypted-message-payload. Kinesis sink is publishing raw-message-payload to kinesis stream but if message payload is encrypted then kinesis-sink should also publish message with `EncryptionContext`. so, we need a mechanism to publish a kinesis message with encrypted-payload and `EncryptionContext` in it. Adding option to publish message in json-format with message-payload and EncryptionContext. it can be also extended to publish msg in protobuf in future if requires. ### Result Kinesis sink will be able to publish message in json format with payload + encryptionCtx + user-properties.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
