File tree Expand file tree Collapse file tree 2 files changed +24
-8
lines changed Expand file tree Collapse file tree 2 files changed +24
-8
lines changed Original file line number Diff line number Diff line change 2
2
3
3
This module demonstrates how to use the processing exception handler to manage processing errors in Kafka Streams DSL operations.
4
4
5
- ## Run
5
+ ## Prerequisites
6
+
7
+ To compile and run this demo, you’ll need:
8
+
9
+ - Java 21
10
+ - Maven
11
+ - Docker
12
+
13
+ ## Running the Application
6
14
7
15
To run the application manually:
8
16
@@ -22,9 +30,9 @@ This will start the following services in Docker:
22
30
- 1 Control Center
23
31
- 1 Kafka Streams Processing Exception Handler DSL
24
32
25
- ## Try it
33
+ ## Try It Out
26
34
27
- From Control Center running at http://localhost:9021 , you can produce ` DeliveryBooked ` events to the ` delivery_booked_topic ` topic.
35
+ Using Control Center at http://localhost:9021 , you can produce ` DeliveryBooked ` events to the ` delivery_booked_topic ` topic.
28
36
29
37
### Example Record
30
38
47
55
48
56
### Triggering an Exception
49
57
50
- To trigger the processing exception handler, produce a record with missing ` numberOfTires ` , which will result in a ` NullPointerException ` :
58
+ To trigger the processing exception handler, produce a record with a missing ` numberOfTires ` field. This will result in a ` NullPointerException ` :
51
59
52
60
``` json
53
61
{
Original file line number Diff line number Diff line change 2
2
3
3
This module demonstrates how to use the processing exception handler to manage processing errors in Kafka Streams Processor API.
4
4
5
- ## Run
5
+ ## Prerequisites
6
+
7
+ To compile and run this demo, you’ll need:
8
+
9
+ - Java 21
10
+ - Maven
11
+ - Docker
12
+
13
+ ## Running the Application
6
14
7
15
To run the application manually:
8
16
@@ -22,9 +30,9 @@ This will start the following services in Docker:
22
30
- 1 Control Center
23
31
- 1 Kafka Streams Processing Exception Handler Processor API
24
32
25
- ## Try it
33
+ ## Try It Out
26
34
27
- From Control Center running on http://localhost:9021 , you can produce ` DeliveryBooked ` events to the ` delivery_booked_topic ` topic.
35
+ Using Control Center at http://localhost:9021 , you can produce ` DeliveryBooked ` events to the ` delivery_booked_topic ` topic.
28
36
29
37
### Example Record
30
38
47
55
48
56
### Triggering an Exception
49
57
50
- To trigger the processing exception handler, produce a record with missing ` numberOfTires ` , which will result in a ` NullPointerException ` :
58
+ To trigger the processing exception handler, produce a record with a missing ` numberOfTires ` field. This will result in a ` NullPointerException ` :
51
59
52
60
``` json
53
61
{
You can’t perform that action at this time.
0 commit comments