[KAFKA-2470] kafka-producer-perf-test.sh can't configure all to request-num-acks

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.2.1
• Fix Version/s: 0.9.0.0
• Component/s: clients, tools
• Environment: Linux
• Assignee: Unassigned
• Reporter: Bo Wang
• Created: 25/Aug/15 12:05
• Updated: 04/Nov/15 09:11
• Resolved: 04/Nov/15 09:11

Description

For New Producer API, kafka-producer-perf-test.sh can't configure all to request-num-acks :
bin]# ./kafka-producer-perf-test.sh --topic test --broker-list host:port --messages 1000000 --message-size 200 --new-producer --sync --batch-size 1
--request-num-acks all
Exception in thread "main" joptsimple.OptionArgumentConversionException: Cannot convert argument 'all' of option ['request-num-acks'] to class java.lang.Integer
at joptsimple.ArgumentAcceptingOptionSpec.convert(ArgumentAcceptingOptionSpec.java:237)
at joptsimple.OptionSet.valuesOf(OptionSet.java:226)
at joptsimple.OptionSet.valueOf(OptionSet.java:170)
at kafka.tools.ProducerPerformance$ProducerPerfConfig.<init>(ProducerPerformance.scala:146)
at kafka.tools.ProducerPerformance$.main(ProducerPerformance.scala:42)
at kafka.tools.ProducerPerformance.main(ProducerPerformance.scala)
Caused by: joptsimple.internal.ReflectionException: java.lang.NumberFormatException: For input string: "all"
at joptsimple.internal.Reflection.reflectionException(Reflection.java:136)
at joptsimple.internal.Reflection.invoke(Reflection.java:123)
at joptsimple.internal.MethodInvokingValueConverter.convert(MethodInvokingValueConverter.java:48)
at joptsimple.ArgumentAcceptingOptionSpec.convert(ArgumentAcceptingOptionSpec.java:234)
... 5 more