...
| Code Block |
|---|
1. Check out kafka codebase:
a. ~ $ git clone https://git-wip-us.apache.org/repos/asf/kafka.git
b. ~ $ cd <kafka>
2. Under <kafka>, build kafka
a. <kafka> $ ./gradlew 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
|
...