Skip to content

Commit a92af8d

Browse files
committed
Adding Kafka Source details on delivery spec
Signed-off-by: Matthias Wessendorf <mwessend@redhat.com>
1 parent 9b8fd63 commit a92af8d

File tree

1 file changed

+33
-0
lines changed

1 file changed

+33
-0
lines changed

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

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,39 @@ can add to the `config-kafka-features` configmap, [read about the experimental K
266266
}
267267
```
268268

269+
## Handling Delivery Failures
270+
271+
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:
272+
273+
```yaml
274+
apiVersion: sources.knative.dev/v1beta1
275+
kind: KafkaSource
276+
metadata:
277+
name: kafka-source
278+
spec:
279+
consumerGroup: knative-group
280+
bootstrapServers:
281+
- my-cluster-kafka-bootstrap.kafka:9092 # note the kafka namespace
282+
topics:
283+
- knative-demo-topic
284+
delivery:
285+
deadLetterSink:
286+
ref:
287+
apiVersion: serving.knative.dev/v1
288+
kind: Service
289+
name: example-sink
290+
backoffDelay: <duration>
291+
backoffPolicy: <policy-type>
292+
retry: <integer>
293+
sink:
294+
ref:
295+
apiVersion: serving.knative.dev/v1
296+
kind: Service
297+
name: event-display
298+
```
299+
300+
The `delivery` API is discussed in the [Handling Delivery Failure](../../event-delivery) chapter.
301+
269302
## Optional: Specify the key deserializer
270303

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

0 commit comments

Comments
 (0)