kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ashish K Singh (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-2470) kafka-producer-perf-test.sh can't configure all to request-num-acks
Date Fri, 28 Aug 2015 17:44:47 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14720307#comment-14720307
] 

Ashish K Singh commented on KAFKA-2470:
---------------------------------------

I do not think that is an issue as it only takes integer as value for {{--request-num-acks}}.
Below is excerpt form help message.

{code}
--request-num-acks <Integer>            Number of acks required for producer   
                                          request to complete (default: -1)  
{code}

> 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)

Mime
View raw message