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

Jeff Holoman commented on FLUME-3076:
-------------------------------------

Yes this is indeed a doc bug. Thanks for catching it. Will update.


> property flumeBatchSize in kafka sink confused
> ----------------------------------------------
>
>                 Key: FLUME-3076
>                 URL: https://issues.apache.org/jira/browse/FLUME-3076
>             Project: Flume
>          Issue Type: Documentation
>          Components: Docs
>    Affects Versions: 1.7.0
>         Environment: CentOS release 6.4 (Final)
>            Reporter: Kamil June
>            Priority: Critical
>              Labels: documentation
>   Original Estimate: 12h
>  Remaining Estimate: 12h
>
> REF: 
> https://archive.cloudera.com/cdh5/cdh/5/flume-ng/FlumeUserGuide.html#kafka-sink
> Original in example:
> {quote}
> a1.sinks.k1.channel = c1
> a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink
> a1.sinks.k1.kafka.topic = mytopic
> a1.sinks.k1.kafka.bootstrap.servers = localhost:9092
> *a1.sinks.k1.kafka.flumeBatchSize = 20*
> a1.sinks.k1.kafka.producer.acks = 1
> a1.sinks.k1.kafka.producer.linger.ms = 1
> a1.sinks.ki.kafka.producer.compression.type = snappy
> {quote}
> *a1.sinks.k1.kafka.flumeBatchSize* doesn't make any sense, the batch size 
> will be set to default (100), after I change it to:
> {quote}
> *a1.sinks.k1.flumeBatchSize = 20*
> {quote}
> everything works fine :)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to