Merge pull request quarkusio#8520 from jharting/kafka-streams-guide-f…

…ix-compiler-errors fix compiler errors in kafka-streams guide
matejvasek · Apr 14, 2020 · fcf329b · fcf329b
2 parents f6aac57 + 09e7859
commit fcf329b
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/docs/src/main/asciidoc/kafka-streams.adoc b/docs/src/main/asciidoc/kafka-streams.adoc
@@ -159,15 +159,15 @@ public class ValuesGenerator {
                             .setScale(1, RoundingMode.HALF_UP)
                             .doubleValue();
 
-                    LOG.info("station: {}, temperature: {}", station.name, temperature);
+                    LOG.infov("station: {0}, temperature: {1}", station.name, temperature);
                     return KafkaRecord.of(station.id, Instant.now() + ";" + temperature);
                 });
     }
 
     @Outgoing("weather-stations")                               // <3>
     public Flowable<KafkaRecord<Integer, String>> weatherStations() {
         List<KafkaRecord<Integer, String>> stationsAsJson = stations.stream()
-            .map(s -> KafkaMessage.of(
+            .map(s -> KafkaRecord.of(
                     s.id,
                     "{ \"id\" : " + s.id +
                     ", \"name\" : \"" + s.name + "\" }"))
@@ -297,6 +297,7 @@ import java.math.RoundingMode;
 
 import io.quarkus.runtime.annotations.RegisterForReflection;
 
+@RegisterForReflection
 public class Aggregation {
 
     public int stationId;