1

我正在尝试触发 Kubeless 函数（编写为 Java 方法），但它似乎不起作用。我已经尝试了所有我能想到的尝试，但我已经没有想法了。下面是 Java 方法（现在它基本上是一个回显服务）。

package io.kubeless;

import io.kubeless.Context;
import io.kubeless.Event;

public class MyHandler {
    public String handle(Event event, Context context) {
        return event.Data;
    }
}

该方法是使用以下方法部署的：

$ kubeless function deploy my-handler --runtime java1.8 --handler MyHandler.handle --from-file src/main/java/io/kubeless/MyHandler.java

我已经通过运行以下命令验证了它的工作原理：

$ kubeless function call my-handler --data "It works"
$ kubectl logs my-handler-6f67d567c5-r8cdb
    0 [pool-1-thread-38] INFO io.kubeless.Handler  - Response: It works

然后，我创建了一个 Kafka 触发器并使用以下内容向其发布了一条消息。

$ kubeless trigger kafka create test --function-selector created-by=kubeless,function=my-handler --trigger-topic test-topic
$ kubeless topic publish --topic test-topic --data "Hello from Kafka"
$ kubectl logs my-handler-6f67d567c5-r8cdb
    0 [pool-1-thread-38] INFO io.kubeless.Handler  - Response: It works

如您所见，唯一的日志条目是初始调用中未被 Kafka 发布/订阅触发的日志条目。我已验证触发器存在：

$ kubeless trigger kafka ls
NAME    NAMESPACE   TOPIC       FUNCTION SELECTOR
test    default     test-topic  function=my-handler

据我所知，Kafka 似乎正在运行（我还检查了 Kafka 日志，但无济于事）：

$ kubectl get pods --namespace=kubeless
NAME                                          READY   STATUS    RESTARTS   AGE
kafka-0                                       1/1     Running   0          170m
kafka-trigger-controller-f6f7c699f-m6mcd      1/1     Running   0          170m
kubeless-controller-manager-59d484f4d-9wlhq   3/3     Running   10         4d22h
zoo-0                                         1/1     Running   0          170m

为什么发布不触发该功能？任何建议表示赞赏，我提前感谢您。

4

1 回答 1

2

我对此感到厌烦，并且 Kubeless kafka-trigger存在问题。本质上，当控制器接收到消息并尝试触发该功能时，我会收到此日志：

time="2020-07-14T22:00:15Z" level=error msg="Unable to elaborate request: Unable to find the service for function my-handler"

这意味着控制器找不到my-handler触发该功能的服务。如果您看到代码，您会看到它是对 K8s API 服务器的调用。所以，我的猜测是较新的 K8s 版本存在 API 版本不匹配。我的服务器是v1.18.2. 我创建了这个问题来跟踪。

于 2020-07-14T22:17:27.543 回答