小编ARY*_*RYA的帖子

我的包结构为：

    src ->  test -> scala -> notification

内部通知我有两个包单元和集成。

单元包有单元测试，集成包有集成测试。我只想执行单元测试用例。我有没有办法只能通过 sbt 测试来做到这一点？

对于一节课，我知道可以这样做：我已经尝试过一节课，但不知道如何为 pacakge 做到这一点。

sbt "test:testOnly *LoginServiceSpec"

我想要生产者将消息插入到 kafka 主题中的时间戳。

在卡夫卡消费者端，我想提取该时间戳。

class Producer {
  def main(args: Array[String]): Unit = {
    writeToKafka("quick-start")
  }
  def writeToKafka(topic: String): Unit = {
    val props = new Properties()
    props.put("bootstrap.servers", "localhost:9094")
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    val producer = new KafkaProducer[String, String](props)
    val record = new ProducerRecord[String, String](topic, "key", "value")
    producer.send(record)
    producer.close()
  }
}



class Consumer {
  def main(args: Array[String]): Unit = {
    consumeFromKafka("quick-start")
  }
  def consumeFromKafka(topic: String) = {
    val props = new Properties()
    props.put("bootstrap.servers", "localhost:9094")
    props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
    props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
    props.put("auto.offset.reset", "latest")
    props.put("group.id", …