Skip to content

Commit

Permalink
Switch to JBoss Logging in Kafka Streams guide
Browse files Browse the repository at this point in the history
  • Loading branch information
gsmet committed Apr 14, 2020
1 parent 45a6a8f commit 09e7859
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions docs/src/main/asciidoc/kafka-streams.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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();
Expand Down Expand Up @@ -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);
});
}
Expand Down

0 comments on commit 09e7859

Please sign in to comment.