Skip to content

Commit 2fc233e

Browse files
authored
Adding Kafka Source details on delivery spec (#5952)
Signed-off-by: Matthias Wessendorf <mwessend@redhat.com>
1 parent 9b8fd63 commit 2fc233e

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

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

0 commit comments

Comments
 (0)