File tree 1 file changed +9
-7
lines changed
1 file changed +9
-7
lines changed Original file line number Diff line number Diff line change 1
- # Processing Error Handling with DSL
1
+ # Handling Processing Errors in Kafka Streams DSL
2
2
3
- This module demonstrates how the processing exception handler can be used to handle processing exceptions in Kafka Streams DSL operations.
3
+ This module demonstrates how to use the processing exception handler to manage processing errors in Kafka Streams DSL operations.
4
4
5
5
## Run
6
6
@@ -24,11 +24,13 @@ This will start the following services in Docker:
24
24
25
25
## Try it
26
26
27
- From Control Center running on http://localhost:9021 , you can produce ` DeliveryBooked ` events to the topic ` delivery_booked_topic ` .
27
+ From Control Center running at http://localhost:9021 , you can produce ` DeliveryBooked ` events to the ` delivery_booked_topic ` topic.
28
+
29
+ ### Example Record
28
30
29
31
Key:
30
32
31
- ```
33
+ ``` json
32
34
" DEL12345"
33
35
```
34
36
@@ -43,14 +45,14 @@ Value:
43
45
}
44
46
```
45
47
46
- To trigger the processing exception handler, you can produce a record with an incorrect format:
48
+ ### Triggering an Exception
47
49
48
- Value with missing ` numberOfTires ` , triggering a ` NullPointerException ` :
50
+ To trigger the processing exception handler, produce a record with missing ` numberOfTires ` , which will result in a ` NullPointerException ` :
49
51
50
52
``` json
51
53
{
52
54
"deliveryId" : " DEL12345" ,
53
55
"truckId" : " TRK56789" ,
54
56
"destination" : " Bordeaux"
55
57
}
56
- ```
58
+ ```
You can’t perform that action at this time.
0 commit comments