[
https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Wang updated KAFKA-2470:
---------------------------
Fix Version/s: 0.8.3
> kafka-producer-perf-test.sh can't configure all to request-num-acks
> -------------------------------------------------------------------
>
> Key: KAFKA-2470
> URL: https://issues.apache.org/jira/browse/KAFKA-2470
> Project: Kafka
> Issue Type: Bug
> Components: clients, tools
> Affects Versions: 0.8.2.1
> Environment: Linux
> Reporter: Bo Wang
> Fix For: 0.8.3
>
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> 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
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
