From 45a6a8fbf19d01a108586f5b0ca08fc244ef513c Mon Sep 17 00:00:00 2001 From: Jozef Hartinger Date: Fri, 10 Apr 2020 14:58:30 +0200 Subject: [PATCH 1/2] fix compiler errors in kafka-streams guide --- docs/src/main/asciidoc/kafka-streams.adoc | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/docs/src/main/asciidoc/kafka-streams.adoc b/docs/src/main/asciidoc/kafka-streams.adoc index 4b33cc09b9a64..8c9098fcb8313 100644 --- a/docs/src/main/asciidoc/kafka-streams.adoc +++ b/docs/src/main/asciidoc/kafka-streams.adoc @@ -116,7 +116,8 @@ import java.util.stream.Collectors; import javax.enterprise.context.ApplicationScoped; import org.eclipse.microprofile.reactive.messaging.Outgoing; -import org.jboss.logging.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import io.reactivex.Flowable; import io.smallrye.reactive.messaging.kafka.KafkaRecord; @@ -130,7 +131,7 @@ import io.smallrye.reactive.messaging.kafka.KafkaRecord; @ApplicationScoped public class ValuesGenerator { - private static final Logger LOG = Logger.getLogger(ValuesGenerator.class); + private static final Logger LOG = LoggerFactory.getLogger(ValuesGenerator.class); private Random random = new Random(); @@ -167,7 +168,7 @@ public class ValuesGenerator { @Outgoing("weather-stations") // <3> public Flowable> weatherStations() { List> stationsAsJson = stations.stream() - .map(s -> KafkaMessage.of( + .map(s -> KafkaRecord.of( s.id, "{ \"id\" : " + s.id + ", \"name\" : \"" + s.name + "\" }")) @@ -297,6 +298,7 @@ import java.math.RoundingMode; import io.quarkus.runtime.annotations.RegisterForReflection; +@RegisterForReflection public class Aggregation { public int stationId; From 09e78592b9c77592a91d262a4a52b0ba7de10204 Mon Sep 17 00:00:00 2001 From: Guillaume Smet Date: Tue, 14 Apr 2020 10:09:29 +0200 Subject: [PATCH 2/2] Switch to JBoss Logging in Kafka Streams guide --- docs/src/main/asciidoc/kafka-streams.adoc | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/docs/src/main/asciidoc/kafka-streams.adoc b/docs/src/main/asciidoc/kafka-streams.adoc index 8c9098fcb8313..ba4129f221a1e 100644 --- a/docs/src/main/asciidoc/kafka-streams.adoc +++ b/docs/src/main/asciidoc/kafka-streams.adoc @@ -116,8 +116,7 @@ import java.util.stream.Collectors; import javax.enterprise.context.ApplicationScoped; import org.eclipse.microprofile.reactive.messaging.Outgoing; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; +import org.jboss.logging.Logger; import io.reactivex.Flowable; import io.smallrye.reactive.messaging.kafka.KafkaRecord; @@ -131,7 +130,7 @@ import io.smallrye.reactive.messaging.kafka.KafkaRecord; @ApplicationScoped public class ValuesGenerator { - private static final Logger LOG = LoggerFactory.getLogger(ValuesGenerator.class); + private static final Logger LOG = Logger.getLogger(ValuesGenerator.class); private Random random = new Random(); @@ -160,7 +159,7 @@ 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); }); }