Repository: flume Updated Branches: refs/heads/trunk 38f0b316d -> 5f6d6c3b1
FLUME-2737: Documentation for Pollable Source config parameters introduced in FLUME-2729 (Ted Malaska via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/5f6d6c3b Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/5f6d6c3b Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/5f6d6c3b Branch: refs/heads/trunk Commit: 5f6d6c3b1d0100c57c2656fcd014dc2ee8e0a607 Parents: 38f0b31 Author: Jarek Jarcec Cecho <[email protected]> Authored: Tue Jul 14 09:29:30 2015 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Tue Jul 14 09:29:30 2015 -0700 ---------------------------------------------------------------------- flume-ng-doc/sphinx/FlumeUserGuide.rst | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/5f6d6c3b/flume-ng-doc/sphinx/FlumeUserGuide.rst ---------------------------------------------------------------------- diff --git a/flume-ng-doc/sphinx/FlumeUserGuide.rst b/flume-ng-doc/sphinx/FlumeUserGuide.rst index 175aa10..617e730 100644 --- a/flume-ng-doc/sphinx/FlumeUserGuide.rst +++ b/flume-ng-doc/sphinx/FlumeUserGuide.rst @@ -1152,6 +1152,13 @@ Property Name Default Description batchSize 1000 Maximum number of messages written to Channel in one batch batchDurationMillis 1000 Maximum time (in ms) before a batch will be written to Channel The batch will be written whenever the first of size and time will be reached. +backoffSleepIncrement 1000 Initial and incremental wait time that is triggered when a Kafka Topic appears to be empty. + Wait period will reduce aggressive pinging of an empty Kafka Topic. One second is ideal for + ingestion use cases but a lower value may be required for low latency operations with + interceptors. +maxBackoffSleep 5000 Maximum wait time that is triggered when a Kafka Topic appears to be empty. Five seconds is + ideal for ingestion use cases but a lower value may be required for low latency operations + with interceptors. Other Kafka Consumer Properties -- These properties are used to configure the Kafka Consumer. Any producer property supported by Kafka can be used. The only requirement is to prepend the property name with the prefix ``kafka.``. For example: kafka.consumer.timeout.ms
