From af7b10002a724d527d5467545726bd5b83be633e Mon Sep 17 00:00:00 2001 From: "Filipponi, Luca (ELS)" Date: Sun, 29 Sep 2019 12:38:13 +0100 Subject: [PATCH] removed the log about logback status at startup --- README.md | 6 +++++- src/main/resources/logback.xml | 5 +++-- src/main/scala/com/filipponi/seeker/MsgSeeker.scala | 2 +- 3 files changed, 9 insertions(+), 4 deletions(-) diff --git a/README.md b/README.md index d52882d..d362a6b 100644 --- a/README.md +++ b/README.md @@ -24,4 +24,8 @@ You can build your own jar using sbt: sbt clean assembly ``` -This will run tests as well (will take less than a minute). \ No newline at end of file +This will run tests as well (will take less than a minute). You can skip test in this way: + +``` +sbt "set test in assembly := {}" clean assembly +``` \ No newline at end of file diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml index 4816e9e..a92c144 100644 --- a/src/main/resources/logback.xml +++ b/src/main/resources/logback.xml @@ -1,4 +1,5 @@ + @@ -6,10 +7,10 @@ - + - + \ No newline at end of file diff --git a/src/main/scala/com/filipponi/seeker/MsgSeeker.scala b/src/main/scala/com/filipponi/seeker/MsgSeeker.scala index de536e7..4fed7a0 100644 --- a/src/main/scala/com/filipponi/seeker/MsgSeeker.scala +++ b/src/main/scala/com/filipponi/seeker/MsgSeeker.scala @@ -31,7 +31,7 @@ object MsgSeeker extends App { val partitionInfos = consumer.partitionsFor(config.topic).asScala //this poll does the trick to assign all the partition to this consumer, otherwise i can't seek. - consumer.poll(Duration.ofSeconds(1)) + consumer.poll(Duration.ofSeconds(5)) partitionInfos.foreach { partitionInfo => consumer.seek(new TopicPartition(partitionInfo.topic(), partitionInfo.partition()), config.offset)