i got it from mails, the key is not used to encrpt messages, just to partion messages.
Yuelin Zheng <[email protected]> 于 2020年11月22日周日 下午4:25写道： > Your point is correct, thank you very much for your reply. I will create > related issues to fix the documentation of the kafka-logger plugin. > > > > > 在 2020-11-22 16:04:22，"Chao Zhang" <[email protected]> 写道： > >Is the key related to encryptions? As far as I know, the Kafka Messages > are > >key/value pairs and keys are used for partition assignment. > > > >Chao Zhang > >https://github.com/tokers > > > >On November 22, 2020 at 3:50:50 PM, Yuelin Zheng ([email protected]) wrote: > > > >The key field does not have a default value, because when the message is > >sent to the Kafka service, the key can be specified as empty. > > > >在 2020-11-22 15:14:37，"Zhiyuan Ju" <[email protected]> 写道： > >>then what's the default key for encrpting message? > >> > >>Yuelin Zheng <[email protected]> 于 2020年11月22日周日 下午1:39写道： > >> > >>> This key is the key used for Kafka to encrypt messages. > >>> > >>> > >>> 在 2020-11-22 13:31:27，"Ming Wen" <[email protected]> 写道： > >>> >What is the meaning of key here? > >>> > > >>> >Yuelin Zheng <[email protected]>于2020年11月22日 周日下午1:21写道： > >>> > > >>> >> Hi, Community, > >>> >> > >>> >> > >>> >> In the schema of the kafka-logger plugin, the key field is > mandatory, > >as > >>> >> shown below: > >>> >> > >>> >> > >>> >> ``` > >>> >> ...... > >>> >> properties = { > >>> >> ...... > >>> >> key = {type = "string"}, > >>> >> ...... > >>> >> }, > >>> >> required = {"broker_list", "kafka_topic", "key"} > >>> >> ...... > >>> >> ``` > >>> >> > >>> >> > >>> >> I think the key field should be optional, because when a message is > >sent > >>> >> to the Kafka service, the key can be specified or empty. So when the > >>> key is > >>> >> empty, it can be used normally. > >>> >> > >>> >> > >>> >> The key should be optional in the schema： > >>> >> > >>> >> > >>> >> ``` > >>> >> ...... > >>> >> properties = { > >>> >> ...... > >>> >> key = {type = "string"}, > >>> >> ...... > >>> >> }, > >>> >> required = {"broker_list", "kafka_topic"} > >>> >> ...... > >>> >> ``` > >>> >> > >>> >> > >>> >> Related issue：https://github.com/apache/apisix/issues/2778 > >>> >> > >>> >> -- > >>> >Thanks, > >>> >Ming Wen, Apache APISIX PMC Chair > >>> >Twitter: _WenMing > >>> >
