diff --git a/quarkus-kafaka-homework/kafka-producer/src/main/java/me/jochrist/kafka/MessageProducer.java b/quarkus-kafaka-homework/kafka-producer/src/main/java/me/jochrist/kafka/MessageProducer.java index e930150..172f416 100644 --- a/quarkus-kafaka-homework/kafka-producer/src/main/java/me/jochrist/kafka/MessageProducer.java +++ b/quarkus-kafaka-homework/kafka-producer/src/main/java/me/jochrist/kafka/MessageProducer.java @@ -9,12 +9,15 @@ import java.sql.Timestamp; import java.util.Date; import java.util.Random; import java.util.concurrent.TimeUnit; +import org.jboss.logging.Logger; @ApplicationScoped public class MessageProducer { + private static final Logger LOG = Logger.getLogger(MessageProducer.class); @Inject @Channel("user-message") Emitter messageEmitter; public void sendMessage(String message) { + LOG.debug("%h emmitting message:\"" + message + "\""); messageEmitter.send(message); } }