healchow commented on code in PR #6753:
URL: https://github.com/apache/inlong/pull/6753#discussion_r1042309796
##########
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java:
##########
@@ -90,6 +90,8 @@ public class KafkaSource extends StreamSource {
@ApiModelProperty(value = "Data field escape symbol")
private String dataEscapeChar;
+ @ApiModelProperty("Whether wrap content with InlongMessage")
+ private boolean wrapWithInlongMessage = true;
Review Comment:
1. Add one blank line before the new field.
2. Suggest changing the field name to `wrapWithInlongMsg`, because
`InlongMsg` is the same as the `InLongMsgXxx`.
```suggestion
@ApiModelProperty("Whether wrap content with InlongMsg")
private boolean wrapWithInlongMsg = true;
```
--
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-unsubscr...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
