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

Reply via email to