14.7. 发现客户端的连接详情
通过服务发现,可以更轻松地在与 Apache Kafka 相同的 OpenShift 集群中运行的客户端应用程序,以便与 Kafka 集群交互。
为以下服务创建服务发现标签和注解:
- 内部 Kafka bootstrap 服务
Kafka Bridge 服务
- 服务发现标签
-
Service资源的服务发现标签strimzi.io/discovery设置为true,使其可以发现客户端连接。 - 服务发现注解
- 服务发现注解以 JSON 格式提供用于建立连接的客户端应用程序的连接详情。
内部 Kafka bootstrap 服务示例
apiVersion: v1
kind: Service
metadata:
annotations:
strimzi.io/discovery: |-
[ {
"port" : 9092,
"tls" : false,
"protocol" : "kafka",
"auth" : "scram-sha-512"
}, {
"port" : 9093,
"tls" : true,
"protocol" : "kafka",
"auth" : "tls"
} ]
labels:
strimzi.io/cluster: my-cluster
strimzi.io/discovery: "true"
strimzi.io/kind: Kafka
strimzi.io/name: my-cluster-kafka-bootstrap
name: my-cluster-kafka-bootstrap
spec:
#...
Kafka Bridge 服务示例
apiVersion: v1
kind: Service
metadata:
annotations:
strimzi.io/discovery: |-
[ {
"port" : 8080,
"tls" : false,
"auth" : "none",
"protocol" : "http"
} ]
labels:
strimzi.io/cluster: my-bridge
strimzi.io/discovery: "true"
strimzi.io/kind: KafkaBridge
strimzi.io/name: my-bridge-bridge-service
在从命令行或对应的 API 调用获取服务时,通过指定发现标签来查找服务。
使用发现标签返回服务
oc get service -l strimzi.io/discovery=true
检索服务发现标签时返回连接详情。