lightzhao commented on code in PR #4243:
URL:
https://github.com/apache/incubator-seatunnel/pull/4243#discussion_r1122665399
##########
docs/en/connector-v2/sink/Kafka.md:
##########
@@ -84,6 +84,10 @@ If name is set as the key, then the hash value of the name
column will determine
If not set partition key fields, the null message key will be sent to.
+The format of the message key is json, If name is set as the key, for example
'{"name":"Jack"}'.
Review Comment:
This is not the format of the message. This is the key format of the message
written to kafka after setting the "partition_key_fields" attribute. For
example, if the "partition_key_fields" attribute is set to name, the key of the
message kafka message should be '{"name": "Jack"}'.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
