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)