Kamil June created FLUME-3076:
---------------------------------
Summary: 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
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)
