CAMEL-9957: Use a worker pool for processing kafka callbacks to not streal its io thread to do camel routing. See the kafka javadoc/documentation.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d5bd35a6 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d5bd35a6 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d5bd35a6 Branch: refs/heads/camel-2.17.x Commit: d5bd35a67e595d08be76edb077b9595e97f90b24 Parents: 1fd632c Author: Claus Ibsen <[email protected]> Authored: Fri May 13 11:31:49 2016 +0200 Committer: Claus Ibsen <[email protected]> Committed: Fri May 13 11:31:49 2016 +0200 ---------------------------------------------------------------------- .../apache/camel/component/kafka/KafkaConfiguration.java | 11 ----------- 1 file changed, 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d5bd35a6/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java index 1a98b28..06f1de1 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java @@ -1154,17 +1154,6 @@ public class KafkaConfiguration { this.valueDeserializer = valueDeserializer; } - public boolean isSeekToBeginning() { - return seekToBeginning; - } - - /** - * If the option is true, then KafkaConsumer will read from beginning on startup. - */ - public void setSeekToBeginning(boolean seekToBeginning) { - this.seekToBeginning = seekToBeginning; - } - public ExecutorService getWorkerPool() { return workerPool; }
