[
https://issues.apache.org/jira/browse/FLUME-3076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Holoman reassigned FLUME-3076:
-----------------------------------
Assignee: Jeff Holoman
> 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
> Assignee: Jeff Holoman
> 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)
