MLHR-1959 #comment Added getter for offset manager so that its properties can be set from property files
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/61217c7f Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/61217c7f Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/61217c7f Branch: refs/heads/master Commit: 61217c7f05c4d3f0017a24a42644b27a23be6457 Parents: 3a8aaba Author: Pramod Immaneni <[email protected]> Authored: Tue Dec 29 18:30:28 2015 -0800 Committer: Pramod Immaneni <[email protected]> Committed: Tue Dec 29 18:33:06 2015 -0800 ---------------------------------------------------------------------- .../datatorrent/contrib/kafka/AbstractKafkaInputOperator.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/61217c7f/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java index ec50615..2343ba2 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java @@ -942,6 +942,11 @@ public abstract class AbstractKafkaInputOperator<K extends KafkaConsumer> implem this.offsetManager = offsetManager; } + public OffsetManager getOffsetManager() + { + return offsetManager; + } + public void setRepartitionCheckInterval(long repartitionCheckInterval) { this.repartitionCheckInterval = repartitionCheckInterval;
