！！！中文社区中说的config.json的方式已经被废弃了，所以现在最好通过minio客户端的方式进行处理了

· 在minio client的可执行目录下执行如下命令，查看是否已经存在配置

./mc --insecure admin config get myminio notify_kafka

不存在就会如下打印：

notify_kafka enable=off topic= brokers= sasl_username= sasl_password= sasl_mechanism=plain client_tls_cert= client_tls_key= tls_client_auth=0 sasl=off tls=off tls_skip_verify=off queue_limit=0 queue_dir= version=

· 添加Kafka通知配置

./mc --insecure admin config set myminio notify_kafka:myinstance tls_skip_verify="off"  queue_dir="" queue_limit="0" sasl="off" sasl_password="" sasl_username="" tls_client_auth="0" tls="off" client_tls_cert="" client_tls_key="" brokers="[YOUR IP]:9092,[YOUR IP]:9093,[YOUR IP]:9094" topic="bucketevents" version="" 

参数说明

KEY:
notify_kafka[:name]  publish bucket notifications to Kafka endpoints

ARGS:
brokers*         (csv)       comma separated list of Kafka broker addresses
topic            (string)    Kafka topic used for bucket notifications
sasl_username    (string)    username for SASL/PLAIN or SASL/SCRAM authentication
sasl_password    (string)    password for SASL/PLAIN or SASL/SCRAM authentication
sasl_mechanism   (string)    sasl authentication mechanism, default 'PLAIN'
tls_client_auth  (string)    clientAuth determines the Kafka server's policy for TLS client auth
sasl             (on|off)    set to 'on' to enable SASL authentication
tls              (on|off)    set to 'on' to enable TLS
tls_skip_verify  (on|off)    trust server TLS without verification, defaults to "on" (verify)
client_tls_cert  (path)      path to client certificate for mTLS auth
client_tls_key   (path)      path to client key for mTLS auth
queue_dir        (path)      staging dir for undelivered messages e.g. '/home/events'
queue_limit      (number)    maximum limit for undelivered messages, defaults to '100000'
version          (string)    specify the version of the Kafka cluster e.g '2.2.0'
comment          (sentence)  optionally add a comment to this settin

添加成功会有成功的提示信息

Setting new key has been successful.
Please restart your server with `mc admin service restart myminio`.

· 在minio client的可执行目录下执行如下命令，查看是否已经存在配置

./mc --insecure admin config get myminio notify_kafka

存在会有如下打印：

notify_kafka:myinstance topic=bucketevents brokers=[YOUR IP]:9092,[YOUR IP]:9093,[YOUR IP]:9094 sasl_username= sasl_password= sasl_mechanism=plain client_tls_cert= client_tls_key= tls_client_auth=0 sasl=off tls=off tls_skip_verify=off queue_limit=0 queue_dir= version= 

要能够使用还需要启动服务（集群的话需要重启每个节点服务）