Skip to content

Commit 6f650e2

Browse files
committed
Checkstyle
1 parent 18c7de8 commit 6f650e2

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

kafka-streams-quickstarts/kafka-streams-exception-handler-production/src/main/java/io/github/loicgreffier/streams/production/exception/handler/app/KafkaStreamsTopology.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public class KafkaStreamsTopology {
2626
* <li>Populates the email field changing the record type from KafkaPerson to KafkaPersonWithEmail.
2727
* As the email field is not nullable, it breaks the schema backward compatibility and triggers a serialization
2828
* exception when registering the schema in the Schema Registry automatically.</li>
29-
* <li>Populates the biography field with a large text that exceeds the maximum record size allowed by Kafka (1MiB).
30-
* It triggers a production exception due to the record being too large.</li>
29+
* <li>Populates the biography field with a large text that exceeds the maximum record size allowed by
30+
* Kafka (1MiB). It triggers a production exception due to the record being too large.</li>
3131
* </li>
3232
* </ul>
3333
* The population of the email field and the biography field is not triggered for all records to avoid generating

kafka-streams-quickstarts/kafka-streams-exception-handler-production/src/test/java/io/github/loicgreffier/streams/production/exception/handler/KafkaStreamsProductionExceptionHandlerApplicationTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,7 @@ private MetricName droppedRecordsRateMetric() {
149149

150150
/**
151151
* Mock Serde that throws an exception when serializing.
152+
*
152153
* @param <T> the type of the record.
153154
*/
154155
public static class SerdeMock<T extends org.apache.avro.specific.SpecificRecord> implements Serde<T> {

0 commit comments

Comments
 (0)