diff --git a/31/connect.html b/31/connect.html index 07f8778f0..f1b4da155 100644 --- a/31/connect.html +++ b/31/connect.html @@ -49,6 +49,7 @@
bootstrap.servers
- List of Kafka servers used to bootstrap connections to Kafka
key.converter
- Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the keys in messages written to or read from Kafka, and since this is independent of connectors it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro.value.converter
- Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the values in messages written to or read from Kafka, and since this is independent of connectors it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro.plugin.path
(default empty
) - a list of paths that contain Connect plugins (connectors, converters, transformations). Before running quick starts, users must add the absolute path that contains the example FileStreamSourceConnector and FileStreamSinkConnector packaged in connect-file-"version".jar
, because these connectors are not included by default to the CLASSPATH
or the plugin.path
of the Connect worker (see plugin.path property for examples).The important configuration options specific to standalone mode are:
diff --git a/31/generated/admin_client_config.html b/31/generated/admin_client_config.html index c85bad7fe..9dd1206bf 100644 --- a/31/generated/admin_client_config.html +++ b/31/generated/admin_client_config.html @@ -274,7 +274,7 @@Controls how to read messages written transactionally. If set to read_committed
, consumer.poll() will only return transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional messages which have been aborted. Non-transactional messages will be returned unconditionally in either mode.
Messages will always be returned in offset order. Hence, in read_committed
mode, consumer.poll() will only return messages up to the last stable offset (LSO), which is the one less than the offset of the first open transaction. In particular any messages appearing after messages belonging to ongoing transactions will be withheld until the relevant transaction has been completed. As a result, read_committed
consumers will not be able to read up to the high watermark when there are in flight transactions.
Further, when in read_committed
the seekToEnd method will return the LSO
Controls how to read messages written transactionally. If set to read_committed
, consumer.poll() will only return transactional messages which have been committed. If set to read_uncommitted
(the default), consumer.poll() will return all messages, even transactional messages which have been aborted. Non-transactional messages will be returned unconditionally in either mode.
Messages will always be returned in offset order. Hence, in read_committed
mode, consumer.poll() will only return messages up to the last stable offset (LSO), which is the one less than the offset of the first open transaction. In particular any messages appearing after messages belonging to ongoing transactions will be withheld until the relevant transaction has been completed. As a result, read_committed
consumers will not be able to read up to the high watermark when there are in flight transactions.
Further, when in read_committed
the seekToEnd method will return the LSO