消息投递（从集群外）
从集群外使用生产者、消费者与 kafka 进行消息投递。
前提条件
-
确保 KafkaUser 实例的认证及授权方式与 Kafka 实例一致。
-
确保已完成 加密配置 。
消息投递（TLS 认证）
| external.tls | authentification.type | authorization.type |
|---|---|---|
| true | tls | simple |
说明：
-
主机端口 可在容器平台的 配置 > 内部路由 页面，从名称为 {Kafka 实例名称}-kafka-external-bootstrap 的内部路由中获得。
-
若创建 KafkaTopic 实例时若未设置 Topic Name，上述 Topic 名称 即 KafkaTopic 实例名称。
-
文件路径请以实际情况为准。
发送消息
{文件路径}/kafka-console-producer.sh --bootstrap-server {集群节点 IP}:{主机端口} --topic {Topic 名称} --producer.config {文件路径}/client-ssl.properties
>hello1
>hello2
>hello3
>读取消息
{文件路径}/kafka-console-consumer.sh --bootstrap-server {集群节点 IP}:{主机端口} --topic {Topic 名称} --consumer.config {文件路径}/client-ssl.properties --from-beginning --group my-group
hello1
hello2
hello3消息投递（scram-sha-512 认证）
| external.tls | authentification.type | authorization.type |
|---|---|---|
| true | scram-sha-512 | simple |
说明：
-
主机端口 可在容器平台的 配置 > 内部路由 页面，从名称为 {Kafka 实例名称}-kafka-external-bootstrap 的内部路由中获得。
-
若创建 KafkaTopic 实例时若未设置 Topic Name，Topic 名称 即 KafkaTopic 实例名称。
-
文件路径请以实际情况为准。
发送消息
{文件路径}/kafka-console-producer.sh --bootstrap-server {集群节点 IP}:{主机端口} --topic {Topic 名称} --producer.config {文件路径}/client.properties
>hello1
>hello2
>hello3
>读取消息
$ {文件路径}/kafka-console-consumer.sh --bootstrap-server {集群节点 IP}:{主机端口} --topic {Topic 名称} --consumer.config {文件路径}/client.properties --from-beginning --group my-group
hello1
hello2
hello3