Docs regenerated
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/aaf0e47a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/aaf0e47a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/aaf0e47a Branch: refs/heads/master Commit: aaf0e47a524fb55504555c06985fbfcc0d8c25f6 Parents: 115c93a Author: Andrea Cosentino <anco...@gmail.com> Authored: Mon Nov 21 09:47:11 2016 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Mon Nov 21 09:47:11 2016 +0100 ---------------------------------------------------------------------- components/camel-kafka/src/main/docs/kafka-component.adoc | 2 +- .../org/apache/camel/component/kafka/KafkaConfiguration.java | 6 ++---- 2 files changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/aaf0e47a/components/camel-kafka/src/main/docs/kafka-component.adoc ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/docs/kafka-component.adoc b/components/camel-kafka/src/main/docs/kafka-component.adoc index 3f48ca4..3966f5d 100644 --- a/components/camel-kafka/src/main/docs/kafka-component.adoc +++ b/components/camel-kafka/src/main/docs/kafka-component.adoc @@ -122,7 +122,7 @@ The Kafka component supports 77 endpoint options which are listed below: | heartbeatIntervalMs | consumer | 3000 | Integer | The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than session.timeout.ms but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal rebalances. | keyDeserializer | consumer | org.apache.kafka.common.serialization.StringDeserializer | String | Deserializer class for key that implements the Deserializer interface. | maxPartitionFetchBytes | consumer | 1048576 | Integer | The maximum amount of data per-partition the server will return. The maximum total memory used for a request will be partitions max.partition.fetch.bytes. This size must be at least as large as the maximum message size the server allows or else it is possible for the producer to send messages larger than the consumer can fetch. If that happens the consumer can get stuck trying to fetch a large message on a certain partition. -| maxPollRecords | consumer | 500 | Integer | The maximum number of records returned in a single call to poll(). +| maxPollRecords | consumer | 500 | Integer | The maximum number of records returned in a single call to poll() | partitionAssignor | consumer | org.apache.kafka.clients.consumer.RangeAssignor | String | The class name of the partition assignment strategy that the client will use to distribute partition ownership amongst consumer instances when group management is used | pollTimeoutMs | consumer | 5000 | Long | The timeout used when polling the KafkaConsumer. | seekToBeginning | consumer | false | boolean | If the option is true then KafkaConsumer will read from beginning on startup. http://git-wip-us.apache.org/repos/asf/camel/blob/aaf0e47a/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 db7f4dc..7fd5e4c 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 @@ -72,7 +72,7 @@ public class KafkaConfiguration { //session.timeout.ms @UriParam(label = "consumer", defaultValue = "30000") private Integer sessionTimeoutMs = 30000; - @UriParam(label = "consumer", defaultValue = "2147483647") + @UriParam(label = "consumer", defaultValue = "500") private Integer maxPollRecords; @UriParam(label = "consumer", defaultValue = "5000") private Long pollTimeoutMs = 5000L; @@ -1130,9 +1130,7 @@ public class KafkaConfiguration { } /** - * A unique string that identifies the consumer group this consumer belongs to. - * This property is required if the consumer uses either the group management functionality by using - * <code>subscribe(topic)</code> or the Kafka-based offset management strategy. + * The maximum number of records returned in a single call to poll() */ public void setMaxPollRecords(Integer maxPollRecords) { this.maxPollRecords = maxPollRecords;
