Kafka partition problem
At this moment, according to Kafka and zookeeper configuration file. All log-appended files are stored in /tmp/kafka.log/
or /tmp/zookeeper
. These files are supposed to be deleted, thus should be configured so that we could deleted them after each iteration. Storing inside scratch
file seems to be a better idea.
Also, lof4j should be reconfigured. The output seems to be very important for validation.