Hi, In Kafka source code, kafka.utils.TestUtils is defined in src/core/src/test/scala/unit/kafka/utils/TestUtils.scala, but the kafka_2.8.0-0.8.0-beta1.jar doesn't include kafka.utils.TestUtils. I'm wondering how to write java unit test using kafka.utils.TestUtils? Should I use some other jars or to compile one from the scala source code? Sorry if it's a rudimentary question; I know little about scala, just know it can be compiled to java class.
Thanks, Jiang