Description
If you run:
./bin/kafka-verifiable-producer.sh --broker-list <broker-list:9092> --topic test_topic_increasing_p2 --message-create-time <epoch argument> --acks -1 --max-messages 100
the "<epoch argument>" for --message-create-time doesn't take a 13 digit long like 1529656934000.
The error message:
verifiable-producer: error: argument --message-create-time: could not convert '1529656934000' to Integer (For input string: "1529656934000")
When you provide a 10 digit (1529656934) epoch for the argument it does work but this leads to your topic being cleaned up in a few minutes since the retention time is expired.
The error seems to be obvious since VerifiableProducer.java has:
Long createTime = (long) res.getInt("createTime");
when parsing the argument. This should be taken as a Long instead.