You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/04/07 05:55:16 UTC

[GitHub] [pulsar] momo-jun commented on a diff in pull request #14993: Add option to flatten JSON with FULL_MESSAGE_IN_JSON_EXPAND_VALUE format

momo-jun commented on code in PR #14993:
URL: https://github.com/apache/pulsar/pull/14993#discussion_r844714583


##########
site2/docs/io-kinesis-sink.md:
##########
@@ -12,9 +12,11 @@ The configuration of the Kinesis sink connector has the following property.
 
 ### Property
 
-| Name | Type|Required | Default | Description
+| Name | Type | Required | Default | Description
 |------|----------|----------|---------|-------------|
 `messageFormat`|MessageFormat|true|ONLY_RAW_PAYLOAD|Message format in which Kinesis sink converts Pulsar messages and publishes to Kinesis streams.<br/><br/>Below are the available options:<br/><br/><li>`ONLY_RAW_PAYLOAD`: Kinesis sink directly publishes Pulsar message payload as a message into the configured Kinesis stream. <br/><br/><li>`FULL_MESSAGE_IN_JSON`: Kinesis sink creates a JSON payload with Pulsar message payload, properties and encryptionCtx, and publishes JSON payload into the configured Kinesis stream.<br/><br/><li>`FULL_MESSAGE_IN_FB`: Kinesis sink creates a flatbuffer serialized payload with Pulsar message payload, properties and encryptionCtx, and publishes flatbuffer payload into the configured Kinesis stream.<br/><br/><li>`FULL_MESSAGE_IN_JSON_EXPAND_VALUE`: Kinesis sink sends a JSON structure containing the record topic name, key, payload, properties and event time. The record schema is used to convert the value to JSON.
+`jsonIncludeNonNulls`|boolean|false|true|Value that indicates that only properties with non-null values are to be included when using MessageFormat.FULL_MESSAGE_IN_JSON_EXPAND_VALUE.
+`jsonFlatten`|boolean|false|false|When set to true and the message format is FULL_MESSAGE_IN_JSON_EXPAND_VALUE the output JSON will be flattened.

Review Comment:
   ```suggestion
   `jsonFlatten`|boolean|false|false|When it is set to `true` and the message format is `FULL_MESSAGE_IN_JSON_EXPAND_VALUE`, the output JSON is flattened.
   ```



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org