You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/05/13 09:32:03 UTC
[5/5] camel git commit: 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.
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 <da...@apache.org>
Authored: Fri May 13 11:31:49 2016 +0200
Committer: Claus Ibsen <da...@apache.org>
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;
}