Skip to content

Commit ee6bb97

Browse files
committed
Improve deserialization and production exception handlers README
1 parent 6f650e2 commit ee6bb97

File tree

2 files changed

+5
-3
lines changed
  • kafka-streams-quickstarts
    • kafka-streams-exception-handler-deserialization
    • kafka-streams-exception-handler-production

2 files changed

+5
-3
lines changed

kafka-streams-quickstarts/kafka-streams-exception-handler-deserialization/README.md

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
This module demonstrates the following:
44

55
- The usage of the Kafka Streams configuration `default.deserialization.exception.handler` to handle deserialization exceptions.
6-
- The implementation of a custom deserialization exception handler that logs the exceptions and continues processing the stream.
6+
- The implementation of a custom deserialization exception handler.
77
- Unit testing using Topology Test Driver.
88

99
In this module, records of type `<String, KafkaPerson>` are streamed from a topic named `PERSON_TOPIC`.
@@ -12,7 +12,8 @@ The following tasks are performed:
1212
1. Log the received records.
1313
2. Write the records as they are to a new topic named `PERSON_DESERIALIZATION_EXCEPTION_HANDLER_TOPIC`.
1414

15-
The custom deserialization exception handler is invoked when the configured serdes fail to deserialize the input records.
15+
The custom deserialization exception handler is invoked when the configured serdes fail to deserialize the records.
16+
It logs the exceptions and continues processing.
1617

1718
![topology.png](topology.png)
1819

kafka-streams-quickstarts/kafka-streams-exception-handler-production/README.md

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
This module demonstrates the following:
44

55
- The usage of the Kafka Streams configuration `default.production.exception.handler` to handle production and serialization exceptions.
6-
- The implementation of a custom production exception handler that logs the exceptions and either continues processing or fails the pipeline based on the exception type.
6+
- The implementation of a custom production exception handler.
77
- Unit testing using Topology Test Driver.
88

99
In this module, records of type `<String, KafkaPerson>` are streamed from a topic named `PERSON_TOPIC`.
@@ -17,6 +17,7 @@ The following tasks are performed:
1717
3. Write the resulting records to a new topic named `PERSON_PRODUCTION_EXCEPTION_HANDLER_TOPIC`.
1818

1919
The custom production exception handler is invoked when records fail to be sent to Kafka or when the configured serdes fail to serialize the records.
20+
It logs the exceptions and either continues processing or fails the pipeline based on the exception type.
2021

2122
![topology.png](topology.png)
2223

0 commit comments

Comments
 (0)