hello, i am able to run the job now but it loops indefinitely.
can someone send a valid sample of 1.dat as generated by kafka.etl.impl.DataGenerator in the README, please ? mine seems awfully short (see below). >> 3. 1.dat is a sequence file, so if it isn't compressed, you should be >> able to see its contents in plain text. The contents will essentially list >> the kafka server url, the partition number and the topic as well as the >> offset. > > > mine has only 1 line (some encrypted in the middle of it is shown as is): > SEQkafka.etl.KafkaETLKey"org.apache.hadoop.io.BytesWritable$?ړ??tl?3aC+tcp://<ip_of_my_hostA>:9092 > SimpleTestEvent 0 -1
