Skip to content

Commit bd3a322

Browse files
Adding Kafka Source details on delivery spec (#5953)
Signed-off-by: Matthias Wessendorf <mwessend@redhat.com> Co-authored-by: Matthias Wessendorf <mwessend@redhat.com>
1 parent ffa98da commit bd3a322

File tree

1 file changed

+35
-0
lines changed

1 file changed

+35
-0
lines changed

docs/eventing/sources/kafka-source/README.md

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -264,6 +264,41 @@ can add to the `config-kafka-features` configmap, [read about the experimental K
264264
}
265265
```
266266

267+
## Handling Delivery Failures
268+
269+
The `KafkaSource` implements the `Delivery` Specificiation, allowing you to configure event delivery parameters for it, which are applied in cases where an event fails to be delivered:
270+
271+
```yaml
272+
273+
apiVersion: sources.knative.dev/v1beta1
274+
kind: KafkaSource
275+
metadata:
276+
name: kafka-source
277+
spec:
278+
consumerGroup: knative-group
279+
bootstrapServers:
280+
- my-cluster-kafka-bootstrap.kafka:9092 # note the kafka namespace
281+
topics:
282+
- knative-demo-topic
283+
delivery:
284+
deadLetterSink:
285+
ref:
286+
apiVersion: serving.knative.dev/v1
287+
kind: Service
288+
name: example-sink
289+
backoffDelay: <duration>
290+
backoffPolicy: <policy-type>
291+
retry: <integer>
292+
sink:
293+
ref:
294+
apiVersion: serving.knative.dev/v1
295+
kind: Service
296+
name: event-display
297+
298+
```
299+
300+
The `delivery` API is discussed in the [Handling Delivery Failure](../../event-delivery) chapter.
301+
267302
## Optional: Specify the key deserializer
268303

269304
When `KafkaSource` receives a message from Kafka, it dumps the key in the Event extension called

0 commit comments

Comments
 (0)