Skip to content

Commit

Permalink
adjust ch 7
Browse files Browse the repository at this point in the history
  • Loading branch information
robert0714 committed Apr 27, 2022
1 parent e7f704d commit d895cec
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions chapter-07/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -722,7 +722,7 @@ The first two steps in our processor topology (registering the source processors
<td>DSL</td>
</tr>
<tr>
<td><pre>Topology builder = new Topology();
<td valign="top"><pre>Topology builder = new Topology();
builder.addSource(
"Desired State Events",
Serdes.String().deserializer(),
Expand All @@ -738,7 +738,7 @@ builder.addProcessor(
HighWindsFlatmapProcessor::new,
"Reported State Events");
</pre></td>
<td><pre>StreamsBuilder builder = new StreamsBuilder();
<td valign="top"><pre>StreamsBuilder builder = new StreamsBuilder();
KStream String, TurbineState ; desiredStateEvents =
builder.stream("desired-state-events",
Consumed.with(
Expand Down Expand Up @@ -888,7 +888,7 @@ Now that we’ve discussed the individual steps in our DSL refactor, let’s tak
<td>DSL + Processor API</td>
</tr>
<tr>
<td><pre>Topology builder = new Topology();
<td valign="top" ><pre>Topology builder = new Topology();
builder.addSource(
"Desired State Events",
Serdes.String().deserializer(),
Expand Down Expand Up @@ -924,7 +924,7 @@ builder.addSink(
JsonSerdes.DigitalTwin().serializer(),
"Digital Twin Processor");
</pre></td>
<td><pre>StreamsBuilder builder = new StreamsBuilder();
<td valign="top" ><pre>StreamsBuilder builder = new StreamsBuilder();
KStream&lt;String, TurbineState&gt; desiredStateEvents =
builder.stream("desired-state-events",
Consumed.with(
Expand Down

0 comments on commit d895cec

Please sign in to comment.