You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2015/09/01 23:21:46 UTC
[jira] [Updated] (KAFKA-2470) kafka-producer-perf-test.sh can't
configure all to request-num-acks
[ https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gwen Shapira updated KAFKA-2470:
--------------------------------
Fix Version/s: (was: 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
> 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)