This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 481b8c0bfc0e33933f5ebc08af3618798d293e96
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Dec 14 18:51:05 2020 +0100
CAMEL-15946: Regen
---
.../dsl/AtlasMapEndpointBuilderFactory.java | 10 ++---
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 4 +-
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 4 +-
.../DebeziumPostgresEndpointBuilderFactory.java | 4 +-
.../DebeziumSqlserverEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 12 +++---
.../dsl/PlatformHttpEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/RestEndpointBuilderFactory.java | 2 +-
.../dsl/StringTemplateEndpointBuilderFactory.java | 8 ++--
.../dsl/UndertowEndpointBuilderFactory.java | 4 +-
.../dsl/VertxKafkaEndpointBuilderFactory.java | 44 +++++++++++-----------
11 files changed, 50 insertions(+), 50 deletions(-)
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java
index 8111255..4959f0e 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java
@@ -139,10 +139,10 @@ public interface AtlasMapEndpointBuilderFactory {
}
/**
* The Exchange property name for a source message map which hold
- * java.util.Map<String, Message> where the key is AtlasMap
- * Document ID. AtlasMap consumes Message bodies as source documents,
as
- * well as message headers as source properties where the scope equals
- * to Document ID.
+ * java.util.Map&lt;String, Message&gt; where the key is
+ * AtlasMap Document ID. AtlasMap consumes Message bodies as source
+ * documents, as well as message headers as source properties where the
+ * scope equals to Document ID.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -191,7 +191,7 @@ public interface AtlasMapEndpointBuilderFactory {
}
/**
* The Exchange property name for a target document map which hold
- * java.util.Map<String, Object> where the key is AtlasMap
+ * java.util.Map&lt;String, Object&gt; where the key is
AtlasMap
* Document ID. AtlasMap populates multiple target documents into this
* map.
*
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index 3e68590..9a5abaf 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -48,7 +48,7 @@ public interface DebeziumMongodbEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -70,7 +70,7 @@ public interface DebeziumMongodbEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index e242ce0..73b6987 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -48,7 +48,7 @@ public interface DebeziumMySqlEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -70,7 +70,7 @@ public interface DebeziumMySqlEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index 1a389f4..c1f7ed1 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -48,7 +48,7 @@ public interface DebeziumPostgresEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -70,7 +70,7 @@ public interface DebeziumPostgresEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index 8edc8bb..17d1fda 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -48,7 +48,7 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -70,7 +70,7 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
* properties needed by Debezium engine, for example setting
* KafkaOffsetBackingStore), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
index b9843c4..38118b4 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaEndpointBuilderFactory.java
@@ -51,7 +51,7 @@ public interface KafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -73,7 +73,7 @@ public interface KafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -1484,7 +1484,7 @@ public interface KafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -1506,7 +1506,7 @@ public interface KafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -3085,7 +3085,7 @@ public interface KafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -3107,7 +3107,7 @@ public interface KafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
index 196b099..392c976 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
@@ -83,8 +83,8 @@ public interface PlatformHttpEndpointBuilderFactory {
}
/**
* The content type this endpoint accepts as an input, such as
- * application/xml or application/json. null or */* mean no
- * restriction.
+ * application/xml or application/json. null or &#42;/&#42;
mean
+ * no restriction.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
index 7d3931b..ad8ffed 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
@@ -447,7 +447,7 @@ public interface RestEndpointBuilderFactory {
/**
* Query parameters for the HTTP service to call. The query parameters
* can contain multiple parameters separated by ampersand such such as
- * foo=123&bar=456.
+ * foo=123&bar=456.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StringTemplateEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StringTemplateEndpointBuilderFactory.java
index e69db9a..3661843 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StringTemplateEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StringTemplateEndpointBuilderFactory.java
@@ -136,7 +136,7 @@ public interface StringTemplateEndpointBuilderFactory {
*
* The option is a: <code>char</code> type.
*
- * Default: <
+ * Default: <
* Group: producer
*/
default StringTemplateEndpointBuilder delimiterStart(char
delimiterStart) {
@@ -148,7 +148,7 @@ public interface StringTemplateEndpointBuilderFactory {
*
* The option will be converted to a <code>char</code> type.
*
- * Default: <
+ * Default: <
* Group: producer
*/
default StringTemplateEndpointBuilder delimiterStart(
@@ -161,7 +161,7 @@ public interface StringTemplateEndpointBuilderFactory {
*
* The option is a: <code>char</code> type.
*
- * Default: >
+ * Default: >
* Group: producer
*/
default StringTemplateEndpointBuilder delimiterStop(char
delimiterStop) {
@@ -173,7 +173,7 @@ public interface StringTemplateEndpointBuilderFactory {
*
* The option will be converted to a <code>char</code> type.
*
- * Default: >
+ * Default: >
* Group: producer
*/
default StringTemplateEndpointBuilder delimiterStop(String
delimiterStop) {
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/UndertowEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/UndertowEndpointBuilderFactory.java
index 700635d..587d0fc 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/UndertowEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/UndertowEndpointBuilderFactory.java
@@ -738,7 +738,7 @@ public interface UndertowEndpointBuilderFactory {
* Sets additional channel options. The options that can be used are
* defined in org.xnio.Options. To configure from endpoint uri, then
* prefix each option with option., such as
- * option.close-abort=true&option.send-buffer=8192.
+ * option.close-abort=true&option.send-buffer=8192.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -756,7 +756,7 @@ public interface UndertowEndpointBuilderFactory {
* Sets additional channel options. The options that can be used are
* defined in org.xnio.Options. To configure from endpoint uri, then
* prefix each option with option., such as
- * option.close-abort=true&option.send-buffer=8192.
+ * option.close-abort=true&option.send-buffer=8192.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
index 53cedfd..a1e81b9 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/VertxKafkaEndpointBuilderFactory.java
@@ -50,7 +50,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -72,7 +72,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -91,8 +91,8 @@ public interface VertxKafkaEndpointBuilderFactory {
* A list of host/port pairs to use for establishing the initial
* connection to the Kafka cluster. The client will make use of all
* servers irrespective of which servers are specified here for
- * bootstrapping—this list only impacts the initial hosts used to
- * discover the full set of servers. This list should be in the form
+ * bootstrapping&mdash;this list only impacts the initial hosts
used
+ * to discover the full set of servers. This list should be in the form
* host1:port1,host2:port2,.... Since these servers are just used for
* the initial connection to discover the full cluster membership
(which
* may change dynamically), this list need not contain the full set of
@@ -1953,7 +1953,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -1975,7 +1975,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -1994,8 +1994,8 @@ public interface VertxKafkaEndpointBuilderFactory {
* A list of host/port pairs to use for establishing the initial
* connection to the Kafka cluster. The client will make use of all
* servers irrespective of which servers are specified here for
- * bootstrapping—this list only impacts the initial hosts used to
- * discover the full set of servers. This list should be in the form
+ * bootstrapping&mdash;this list only impacts the initial hosts
used
+ * to discover the full set of servers. This list should be in the form
* host1:port1,host2:port2,.... Since these servers are just used for
* the initial connection to discover the full cluster membership
(which
* may change dynamically), this list need not contain the full set of
@@ -2729,11 +2729,11 @@ public interface VertxKafkaEndpointBuilderFactory {
* sent out. However in some circumstances the client may want to
reduce
* the number of requests even under moderate load. This setting
* accomplishes this by adding a small amount of artificial
- * delay—that is, rather than immediately sending out a record
the
- * producer will wait for up to the given delay to allow other records
- * to be sent so that the sends can be batched together. This can be
- * thought of as analogous to Nagle's algorithm in TCP. This setting
- * gives the upper bound on the delay for batching: once we get
+ * delay&mdash;that is, rather than immediately sending out a
record
+ * the producer will wait for up to the given delay to allow other
+ * records to be sent so that the sends can be batched together. This
+ * can be thought of as analogous to Nagle's algorithm in TCP. This
+ * setting gives the upper bound on the delay for batching: once we get
* batch.size worth of records for a partition it will be sent
* immediately regardless of this setting, however if we have fewer
than
* this many bytes accumulated for this partition we will 'linger' for
@@ -2759,11 +2759,11 @@ public interface VertxKafkaEndpointBuilderFactory {
* sent out. However in some circumstances the client may want to
reduce
* the number of requests even under moderate load. This setting
* accomplishes this by adding a small amount of artificial
- * delay—that is, rather than immediately sending out a record
the
- * producer will wait for up to the given delay to allow other records
- * to be sent so that the sends can be batched together. This can be
- * thought of as analogous to Nagle's algorithm in TCP. This setting
- * gives the upper bound on the delay for batching: once we get
+ * delay&mdash;that is, rather than immediately sending out a
record
+ * the producer will wait for up to the given delay to allow other
+ * records to be sent so that the sends can be batched together. This
+ * can be thought of as analogous to Nagle's algorithm in TCP. This
+ * setting gives the upper bound on the delay for batching: once we get
* batch.size worth of records for a partition it will be sent
* immediately regardless of this setting, however if we have fewer
than
* this many bytes accumulated for this partition we will 'linger' for
@@ -3697,7 +3697,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -3719,7 +3719,7 @@ public interface VertxKafkaEndpointBuilderFactory {
* configurations (e.g: new Kafka properties that are not reflected yet
* in Camel configurations), the properties have to be prefixed with
* additionalProperties.. E.g:
- *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro.
*
* The option is a: <code>java.util.Map<java.lang.String,
* java.lang.Object></code> type.
@@ -3737,8 +3737,8 @@ public interface VertxKafkaEndpointBuilderFactory {
* A list of host/port pairs to use for establishing the initial
* connection to the Kafka cluster. The client will make use of all
* servers irrespective of which servers are specified here for
- * bootstrapping—this list only impacts the initial hosts used to
- * discover the full set of servers. This list should be in the form
+ * bootstrapping&mdash;this list only impacts the initial hosts
used
+ * to discover the full set of servers. This list should be in the form
* host1:port1,host2:port2,.... Since these servers are just used for
* the initial connection to discover the full cluster membership
(which
* may change dynamically), this list need not contain the full set of
