Skip to content

Commit ca52472

Browse files
committed
Fix checkstyle
1 parent 90a81a2 commit ca52472

File tree

1 file changed

+2
-1
lines changed
  • kafka-streams-quickstarts/kafka-streams-cogroup/src/main/java/io/github/loicgreffier/streams/cogroup/app

1 file changed

+2
-1
lines changed

kafka-streams-quickstarts/kafka-streams-cogroup/src/main/java/io/github/loicgreffier/streams/cogroup/app/KafkaStreamsTopology.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,8 @@ public static void topology(StreamsBuilder streamsBuilder) {
5050
groupedStreamOne
5151
.cogroup(aggregator)
5252
.cogroup(groupedStreamTwo, aggregator)
53-
.aggregate(() -> new KafkaPersonGroup(new HashMap<>()), Materialized.as(PERSON_COGROUP_AGGREGATE_STATE_STORE))
53+
.aggregate(() -> new KafkaPersonGroup(new HashMap<>()),
54+
Materialized.as(PERSON_COGROUP_AGGREGATE_STATE_STORE))
5455
.toStream()
5556
.to(PERSON_COGROUP_TOPIC);
5657
}

0 commit comments

Comments
 (0)