We use analytics and cookies to understand site traffic. Information about your use of our site is shared with Google for that purpose. Learn more.
This version of the documentation is no longer actively maintained. The site that you are
currently viewing is an archived snapshot.
For up-to-date documentation, see the latest version.
Sink
A sink is an Addressable resource that acts as a link between the Eventing mesh and an entity or system.
We can connect any source to a sink, such as PingSource
and KafkaSink
objects:
apiVersion: sources.knative.dev/v1beta1
kind: PingSource
metadata:
name: test-ping-source
spec:
schedule: "*/1 * * * *"
jsonData: '{"message": "Hello world!"}'
sink:
ref:
apiVersion: eventing.knative.dev/v1alpha1
kind: KafkaSink
name: my-kafka-sink
We can connect a Trigger
object to a sink, so that we can filter events, before sending them to a sink:
apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
name: my-service-trigger
spec:
broker: default
filter:
attributes:
type: dev.knative.foo.bar
myextension: my-extension-value
subscriber:
ref:
apiVersion: eventing.knative.dev/v1alpha1
kind: KafkaSink
name: my-kafka-sink
Knative Sinks
Name | Maintainer | Description |
---|---|---|
KafkaSink | Knative | Send events to a Kafka topic |
RedisSink | Knative | Send events to a Redis Stream |