THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
1. Check out kafka codebase: a. ~ $ git clone https://git-wip-us.apache.org/repos/asf/kafka.git b. ~ $ cd <kafka> c. <kafka> $ git checkout 0.8 2. Under <kafka>, build kafka a. <kafka> $ ./sbt package assembly-package-dependencygradlew jar 3. Edit <kafka>/config/log4j.properties to uncomment the following 2 lines #log4j.logger.kafka.perf=DEBUG, kafkaAppender #log4j.logger.kafka.perf.ProducerPerformance$ProducerThread=DEBUG, kafkaAppender The above 2 lines will make ProducerPerformance print debugging messages (shown below) such that System Test would need to validate data loss. [2013-07-08 09:32:51,933] DEBUG Topic:test_1:ThreadID:0:MessageID:0000000000:xxxxxxxxxxx [2013-07-08 09:32:51,933] DEBUG Topic:test_1:ThreadID:1:MessageID:0000000100:xxxxxxxxxxx 4. Under <kafka>/system_test, execute the following command to start System Test : $ python -u -B system_test_runner.py 2>&1 | tee system_test_output.log |
...