Repository: flume Updated Branches: refs/heads/flume-1.7 90e13ab8b -> fbf76610f
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/fbf76610 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/fbf76610 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/fbf76610 Branch: refs/heads/flume-1.7 Commit: fbf76610f84fe5e7a6b1790a6fd0a72e523cbf34 Parents: 90e13ab 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:30:13 2015 -0700 ---------------------------------------------------------------------- flume-ng-doc/sphinx/FlumeUserGuide.rst | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/fbf76610/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
