能否将Kubernetes服务设为Knative的Sink或订阅者？配置后未触发

可以，Knative Messaging/Eventing支持将标准Kubernetes Service（非Knative Service）配置为订阅者或Sink，但你的Subscription配置未触发服务，可从以下几个方向排查：

1. 验证Kubernetes Service的连通性 #

• 确认java-fake-service-service与Subscription处于同一命名空间，若不在，需在subscriber.ref中添加namespace字段指定服务所在命名空间。
• 从Knative相关组件的Pod（比如KafkaChannel的运行Pod）测试服务访问：

  # 进入KafkaChannel的Pod
  kubectl exec -it <kafka-channel-pod-name> -- /bin/sh
  # 调用服务端点
  curl http://java-fake-service-service/api/echo
  

  若访问失败，先排查Service的基础配置：selector是否匹配后端Pod标签、Pod是否正常运行、端口是否正确暴露。

2. 修正Subscription配置细节 #

你的配置中subscriber同时使用ref和uri，需注意以下几点：

• 若Service使用的不是默认80端口，必须在ref中添加port字段指定端口：

  apiVersion: messaging.knative.dev/v1
  kind: Subscription
  metadata:
    name: java-subscriber-k8s-service
  spec:
    channel:
      apiVersion: messaging.knative.dev/v1beta1
      kind: KafkaChannel
      name: poc-channel-1
    subscriber:
      ref:
        apiVersion: v1
        kind: Service
        name: java-fake-service-service
        port:
          number: 8080 # 替换为你的Service实际端口
      uri: /api/echo
  

• uri需为相对路径，确保服务端能正确处理该路径的请求。

3. 查看Subscription的投递日志 #

通过日志排查调用失败原因：

kubectl logs -l messaging.knative.dev/subscription=java-subscriber-k8s-service -c user-container

常见问题包括DNS解析失败、连接超时、服务返回4xx/5xx错误等，日志会给出具体报错信息。

4. 确认KafkaChannel状态 #

检查KafkaChannel是否正常运行：

kubectl get kafkachannels.messaging.knative.dev poc-channel-1

确保状态为Ready，同时验证Kafka主题中是否有消息产生，排除消息未流入通道的问题。

补充：Kubernetes Service作为Sink的配置示例 #

若要将其作为Sink（比如在Trigger中使用），配置逻辑一致：

apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
  name: k8s-service-sink-trigger
spec:
  broker: default
  subscriber:
    ref:
      apiVersion: v1
      kind: Service
      name: java-fake-service-service
    uri: /api/echo

内容的提问来源于stack exchange，提问作者Sandeep