计时器源¶
IntegrationSource 通过其 timer 属性支持 Timer Kamelet,用于生成具有自定义有效载荷的周期性消息。
计时器源示例¶
生成带有自定义有效负载的周期性消息。
apiVersion: sources.knative.dev/v1alpha1
kind: IntegrationSource
metadata:
name: integration-source-timer
namespace: knative-samples
spec:
timer:
period: 2000
message: "Hello, Eventing Core"
sink:
ref:
apiVersion: eventing.knative.dev/v1
kind: Broker
name: default
在 timer 对象内部,我们定义 period 以及发送到引用的 sink 的消息。
有关 Apache Camel Kamelet timer-source 的更多详细信息。