This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new 58a0b0661fb Docs sync done from apache/pulsar(#f519e22)
58a0b0661fb is described below
commit 58a0b0661fb5037e838dfd133ebe84e670502687
Author: Pulsar Site Updater <[email protected]>
AuthorDate: Sat Jul 9 00:01:40 2022 +0000
Docs sync done from apache/pulsar(#f519e22)
---
site2/website-next/docs/client-libraries-java.md | 1 +
site2/website-next/docs/client-libraries-python.md | 2 +-
site2/website-next/docs/concepts-messaging.md | 61 ++++++++++++++--------
site2/website-next/docs/cookbooks-deduplication.md | 6 +--
site2/website-next/docs/reference-configuration.md | 3 ++
site2/website-next/docs/reference-metrics.md | 2 +
.../versioned_docs/version-2.10.0/about.md | 12 ++---
.../version-2.10.1/reference-configuration.md | 30 +++++++++++
8 files changed, 84 insertions(+), 33 deletions(-)
diff --git a/site2/website-next/docs/client-libraries-java.md
b/site2/website-next/docs/client-libraries-java.md
index 2a3593af2f0..71af800a6e4 100644
--- a/site2/website-next/docs/client-libraries-java.md
+++ b/site2/website-next/docs/client-libraries-java.md
@@ -743,6 +743,7 @@ When you create a consumer, you can use the `loadConf`
configuration. The follow
`autoAckOldestChunkedMessageOnQueueFull`|boolean|Whether to automatically
acknowledge pending chunked messages when the threashold of
`maxPendingChunkedMessage` is reached. If set to `false`, these messages will
be redelivered by their broker. |true
`maxPendingChunkedMessage`|int| The maximum size of a queue holding pending
chunked messages. When the threshold is reached, the consumer drops pending
messages to optimize memory utilization.|10
`expireTimeOfIncompleteChunkedMessageMillis`|long|The time interval to expire
incomplete chunks if a consumer fails to receive all the chunks in the
specified time period. The default value is 1 minute. | 60000
+`ackReceiptEnabled`|boolean| If `ackReceiptEnabled` is enabled, ACK returns a
receipt. The message is resent after getting the receipt.
You can configure parameters if you do not want to use the default
configuration. For a full list, see the Javadoc for the {@inject:
javadoc:ConsumerBuilder:/client/org/apache/pulsar/client/api/ConsumerBuilder}
class.
diff --git a/site2/website-next/docs/client-libraries-python.md
b/site2/website-next/docs/client-libraries-python.md
index 7cd14e63882..4e9dbdf150d 100644
--- a/site2/website-next/docs/client-libraries-python.md
+++ b/site2/website-next/docs/client-libraries-python.md
@@ -74,7 +74,7 @@ The complete Python API reference is available at
[api/python](/api/python).
## Examples
-You can find a variety of Python code examples for the
[pulsar-client](/pulsar-client-cpp/python) library.
+You can find a variety of Python code examples for the `pulsar-client` library.
### Producer example
diff --git a/site2/website-next/docs/concepts-messaging.md
b/site2/website-next/docs/concepts-messaging.md
index f62c0383430..48c19c43454 100644
--- a/site2/website-next/docs/concepts-messaging.md
+++ b/site2/website-next/docs/concepts-messaging.md
@@ -10,7 +10,7 @@ import TabItem from '@theme/TabItem';
````
-Pulsar is built on the
[publish-subscribe](https://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern)
pattern (often abbreviated to pub-sub). In this pattern,
[producers](#producers) publish messages to [topics](#topics);
[consumers](#consumers) [subscribe](#subscription-types) to those topics,
process incoming messages, and send [acknowledgements](#acknowledgement) to the
broker when processing is finished.
+Pulsar is built on the
[publish-subscribe](https://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern)
pattern (often abbreviated to pub-sub). In this pattern,
[producers](#producers) publish messages to [topics](#topics);
[consumers](#consumers) [subscribe](#subscription-types) to those topics,
process incoming messages, and send [acknowledgments](#acknowledgment) to the
broker when processing is finished.
When a subscription is created, Pulsar
[retains](concepts-architecture-overview.md#persistent-storage) all messages,
even if the consumer is disconnected. The retained messages are discarded only
when a consumer acknowledges that all these messages are processed
successfully.
@@ -65,7 +65,7 @@ Producers send messages to brokers synchronously (sync) or
asynchronously (async
| Mode | Description |
|:-----------|-----------|
-| Sync send | The producer waits for an acknowledgement from the broker after
sending every message. If the acknowledgment is not received, the producer
treats the sending operation as a failure.
|
+| Sync send | The producer waits for an acknowledgment from the broker after
sending every message. If the acknowledgment is not received, the producer
treats the sending operation as a failure.
|
| Async send | The producer puts a message in a blocking queue and returns
immediately. The client library sends the message to the broker in the
background. If the queue is full (you can
[configure](reference-configuration.md#broker) the maximum size), the producer
is blocked or fails immediately when calling the API, depending on arguments
passed to the producer. |
### Access mode
@@ -104,12 +104,27 @@ When batching is enabled, the producer accumulates and
sends a batch of messages
In Pulsar, batches are tracked and stored as single units rather than as
individual messages. Consumers unbundle a batch into individual messages.
However, scheduled messages (configured through the `deliverAt` or the
`deliverAfter` parameter) are always sent as individual messages even when
batching is enabled.
-In general, a batch is acknowledged when all of its messages are acknowledged
by a consumer. It means that when **not all** batch messages are acknowledged,
then unexpected failures, negative acknowledgements, or acknowledgement
timeouts can result in a redelivery of all messages in this batch.
+In general, a batch is acknowledged when all of its messages are acknowledged
by a consumer. It means that when **not all** batch messages are acknowledged,
then unexpected failures, negative acknowledgments, or acknowledgment timeouts
can result in a redelivery of all messages in this batch.
-To avoid redelivering acknowledged messages in a batch to the consumer, Pulsar
introduces batch index acknowledgement since Pulsar 2.6.0. When batch index
acknowledgement is enabled, the consumer filters out the batch index that has
been acknowledged and sends the batch index acknowledgement request to the
broker. The broker maintains the batch index acknowledgement status and tracks
the acknowledgement status of each batch index to avoid dispatching
acknowledged messages to the consumer [...]
+To avoid redelivering acknowledged messages in a batch to the consumer, Pulsar
introduces batch index acknowledgment since Pulsar 2.6.0. When batch index
acknowledgment is enabled, the consumer filters out the batch index that has
been acknowledged and sends the batch index acknowledgment request to the
broker. The broker maintains the batch index acknowledgment status and tracks
the acknowledgment status of each batch index to avoid dispatching acknowledged
messages to the consumer. The [...]
-By default, batch index acknowledgement is disabled
(`acknowledgmentAtBatchIndexLevelEnabled=false`). You can enable batch index
acknowledgement by setting the `acknowledgmentAtBatchIndexLevelEnabled`
parameter to `true` at the broker side. Enabling batch index acknowledgement
results in more memory overheads.
+By default, batch index acknowledgment is disabled
(`acknowledgmentAtBatchIndexLevelEnabled=false`). You can enable batch index
acknowledgment by setting the `acknowledgmentAtBatchIndexLevelEnabled`
parameter to `true` at the broker side. Enabling batch index acknowledgment
results in more memory overheads.
+Batch index acknowledgment must also be enabled in the consumer by calling
`.enableBatchIndexAcknowledgment(true);`
+
+For example:
+
+```java
+Consumer<byte[]> consumer = pulsarClient.newConsumer()
+ .newConsumer(Schema.BYTES)
+ .topic(topicName)
+ .subscriptionName(subscriptionName)
+ .subscriptionType(subType)
+ .enableBatchIndexAcknowledgment(true)
+ .subscribe();
+```
+
+
### Chunking
Message chunking enables Pulsar to process large payload messages by splitting
the message into chunks at the producer side and aggregating chunked messages
at the consumer side.
@@ -174,16 +189,16 @@ Messages are received from
[brokers](reference-terminology.md#broker) either syn
Client libraries provide listener implementation for consumers. For example,
the [Java client](client-libraries-java.md) provides a {@inject:
javadoc:MesssageListener:/client/org/apache/pulsar/client/api/MessageListener}
interface. In this interface, the `received` method is called whenever a new
message is received.
-### Acknowledgement
+### Acknowledgment
-The consumer sends an acknowledgement request to the broker after it consumes
a message successfully. Then, this consumed message will be permanently stored,
and be deleted only after all the subscriptions have acknowledged it. If you
want to store the messages that have been acknowledged by a consumer, you need
to configure the [message retention
policy](concepts-messaging.md#message-retention-and-expiry).
+The consumer sends an acknowledgment request to the broker after it consumes a
message successfully. Then, this consumed message will be permanently stored,
and be deleted only after all the subscriptions have acknowledged it. If you
want to store the messages that have been acknowledged by a consumer, you need
to configure the [message retention
policy](concepts-messaging.md#message-retention-and-expiry).
-For batch messages, you can enable batch index acknowledgement to avoid
dispatching acknowledged messages to the consumer. For details about batch
index acknowledgement, see [batching](#batching).
+For batch messages, you can enable batch index acknowledgment to avoid
dispatching acknowledged messages to the consumer. For details about batch
index acknowledgment, see [batching](#batching).
Messages can be acknowledged in one of the following two ways:
-- Being acknowledged individually. With individual acknowledgement, the
consumer acknowledges each message and sends an acknowledgement request to the
broker.
-- Being acknowledged cumulatively. With cumulative acknowledgement, the
consumer **only** acknowledges the last message it received. All messages in
the stream up to (and including) the provided message are not redelivered to
that consumer.
+- Being acknowledged individually. With individual acknowledgment, the
consumer acknowledges each message and sends an acknowledgment request to the
broker.
+- Being acknowledged cumulatively. With cumulative acknowledgment, the
consumer **only** acknowledges the last message it received. All messages in
the stream up to (and including) the provided message are not redelivered to
that consumer.
If you want to acknowledge messages individually, you can use the following
API.
@@ -203,13 +218,13 @@ consumer.acknowledgeCumulative(msg);
:::note
-Cumulative acknowledgement cannot be used in [Shared subscription
type](#subscription-types), because Shared subscription type involves multiple
consumers which have access to the same subscription. In Shared subscription
type, messages are acknowledged individually.
+Cumulative acknowledgment cannot be used in [Shared subscription
type](#subscription-types), because Shared subscription type involves multiple
consumers which have access to the same subscription. In Shared subscription
type, messages are acknowledged individually.
:::
-### Negative acknowledgement
+### Negative acknowledgment
-The [negative acknowledgement](#negative-acknowledgement) mechanism allows you
to send a notification to the broker indicating the consumer did not process a
message. When a consumer fails to consume a message and needs to re-consume
it, the consumer sends a negative acknowledgement (nack) to the broker,
triggering the broker to redeliver this message to the consumer.
+The [negative acknowledgment](#negative-acknowledgment) mechanism allows you
to send a notification to the broker indicating the consumer did not process a
message. When a consumer fails to consume a message and needs to re-consume
it, the consumer sends a negative acknowledgment (nack) to the broker,
triggering the broker to redeliver this message to the consumer.
Messages are negatively acknowledged individually or cumulatively, depending
on the consumption subscription type.
@@ -234,7 +249,7 @@ Consumer<byte[]> consumer = pulsarClient.newConsumer()
Message<byte[]> message = consumer.receive();
-// call the API to send negative acknowledgement
+// call the API to send negative acknowledgment
consumer.negativeAcknowledge(message);
message = consumer.receive();
@@ -279,11 +294,11 @@ If batching is enabled, all messages in one batch are
redelivered to the consume
:::
-### Acknowledgement timeout
+### Acknowledgment timeout
-The acknowledgement timeout mechanism allows you to set a time range during
which the client tracks the unacknowledged messages. After this acknowledgement
timeout (`ackTimeout`) period, the client sends `redeliver unacknowledged
messages` request to the broker, thus the broker resends the unacknowledged
messages to the consumer.
+The acknowledgment timeout mechanism allows you to set a time range during
which the client tracks the unacknowledged messages. After this acknowledgment
timeout (`ackTimeout`) period, the client sends `redeliver unacknowledged
messages` request to the broker, thus the broker resends the unacknowledged
messages to the consumer.
-You can configure the acknowledgement timeout mechanism to redeliver the
message if it is not acknowledged after `ackTimeout` or to execute a timer task
to check the acknowledgement timeout messages during every `ackTimeoutTickTime`
period.
+You can configure the acknowledgment timeout mechanism to redeliver the
message if it is not acknowledged after `ackTimeout` or to execute a timer task
to check the acknowledgment timeout messages during every `ackTimeoutTickTime`
period.
You can also use the redelivery backoff mechanism, redeliver messages with
different delays by setting the number
of times the messages is retried.
@@ -317,11 +332,11 @@ Redelivery count | Redelivery delay
:::note
- If batching is enabled, all messages in one batch are redelivered to the
consumer.
-- Compared with acknowledgement timeout, negative acknowledgement is
preferred. First, it is difficult to set a timeout value. Second, a broker
resends messages when the message processing time exceeds the acknowledgement
timeout, but these messages might not need to be re-consumed.
+- Compared with acknowledgment timeout, negative acknowledgment is preferred.
First, it is difficult to set a timeout value. Second, a broker resends
messages when the message processing time exceeds the acknowledgment timeout,
but these messages might not need to be re-consumed.
:::
-Use the following API to enable acknowledgement timeout.
+Use the following API to enable acknowledgment timeout.
```java
@@ -498,7 +513,7 @@ Consumer<byte[]> consumer =
pulsarClient.newConsumer(Schema.BYTES)
```
-Dead letter topic serves message redelivery, which is triggered by
[acknowledgement timeout](#acknowledgement-timeout) or [negative
acknowledgement](#negative-acknowledgement) or [retry letter
topic](#retry-letter-topic).
+Dead letter topic serves message redelivery, which is triggered by
[acknowledgment timeout](#acknowledgment-timeout) or [negative
acknowledgment](#negative-acknowledgment) or [retry letter
topic](#retry-letter-topic).
:::note
* Currently, dead letter topic is enabled in Shared and Key_Shared
subscription types.
@@ -876,7 +891,7 @@ There are diverse system topics depending on namespaces.
The following table out
| host/port | `heartbeat` | Persistent | 1 | Heartbeat detection |
| User-defined-ns |
[`__change_events`](concepts-multi-tenancy.md#namespace-change-events-and-topic-level-policies)
| Persistent | Default 4 | Topic events |
| User-defined-ns | `__transaction_buffer_snapshot` | Persistent | One per
namespace | Transaction buffer snapshots |
-| User-defined-ns | `${topicName}__transaction_pending_ack` | Persistent | One
per every topic subscription acknowledged with transactions | Acknowledgements
with transactions |
+| User-defined-ns | `${topicName}__transaction_pending_ack` | Persistent | One
per every topic subscription acknowledged with transactions | Acknowledgments
with transactions |
:::note
@@ -903,8 +918,8 @@ Apache Pulsar avoids these and other message delivery
failures using at-least-on
To utilize message redelivery, you need to enable this mechanism before the
broker can resend the unacknowledged messages in Apache Pulsar client. You can
activate the message redelivery mechanism in Apache Pulsar using three methods.
-- [Negative Acknowledgment](#negative-acknowledgement)
-- [Acknowledgement Timeout](#acknowledgement-timeout)
+- [Negative Acknowledgment](#negative-acknowledgment)
+- [Acknowledgment Timeout](#acknowledgment-timeout)
- [Retry letter topic](#retry-letter-topic)
diff --git a/site2/website-next/docs/cookbooks-deduplication.md
b/site2/website-next/docs/cookbooks-deduplication.md
index 21b38c48c7f..702679641d7 100644
--- a/site2/website-next/docs/cookbooks-deduplication.md
+++ b/site2/website-next/docs/cookbooks-deduplication.md
@@ -83,7 +83,7 @@ The instructions for Java, Python, and C++ clients are
different.
values={[{"label":"Java clients","value":"Java clients"},{"label":"Python
clients","value":"Python clients"},{"label":"C++ clients","value":"C++
clients"}]}>
<TabItem value="Java clients">
-To enable message deduplication on a [Java
producer](client-libraries-java.md#producers), set the producer name using the
`producerName` setter, and set the timeout to `0` using the `sendTimeout`
setter.
+To enable message deduplication on a [Java
producer](client-libraries-java#producer), set the producer name using the
`producerName` setter, and set the timeout to `0` using the `sendTimeout`
setter.
```java
@@ -105,7 +105,7 @@ Producer producer = pulsarClient.newProducer()
</TabItem>
<TabItem value="Python clients">
-To enable message deduplication on a [Python
producer](client-libraries-python.md#producers), set the producer name using
`producer_name`, and set the timeout to `0` using `send_timeout_millis`.
+To enable message deduplication on a [Python
producer](client-libraries-python#producer), set the producer name using
`producer_name`, and set the timeout to `0` using `send_timeout_millis`.
```python
@@ -122,7 +122,7 @@ producer = client.create_producer(
</TabItem>
<TabItem value="C++ clients">
-To enable message deduplication on a [C++
producer](client-libraries-cpp.md#producer), set the producer name using
`producer_name`, and set the timeout to `0` using `send_timeout_millis`.
+To enable message deduplication on a [C++
producer](client-libraries-cpp/#create-a-producer), set the producer name using
`producer_name`, and set the timeout to `0` using `send_timeout_millis`.
```cpp
diff --git a/site2/website-next/docs/reference-configuration.md
b/site2/website-next/docs/reference-configuration.md
index 5d2cb1f9db8..a57d02995c0 100644
--- a/site2/website-next/docs/reference-configuration.md
+++ b/site2/website-next/docs/reference-configuration.md
@@ -400,6 +400,7 @@ brokerServiceCompactionThresholdInBytes|If the estimated
backlog size is greater
It's possible to configure some clients by using the appropriate prefix.
|Prefix|Description|
+|---|---|
|brokerClient_| Configure **all** the broker's Pulsar Clients and Pulsar Admin
Clients. These configurations are applied after hard coded configuration and
before the above brokerClient configurations named above.|
|bookkeeper_| Configure the broker's bookkeeper clients used by managed
ledgers and the BookkeeperPackagesStorage bookkeeper client. Takes precedence
over most other configuration values.|
@@ -788,6 +789,7 @@ The following parameters have been deprecated in the
`conf/standalone.conf` file
It's possible to configure some clients by using the appropriate prefix.
|Prefix|Description|
+|---|---|
|brokerClient_| Configure **all** the broker's Pulsar Clients. These
configurations are applied after hard coded configuration and before the above
brokerClient configurations named above.|
#### Deprecated parameters of WebSocket
@@ -864,6 +866,7 @@ The [Pulsar
proxy](concepts-architecture-overview.md#pulsar-proxy) can be config
It's possible to configure some clients by using the appropriate prefix.
|Prefix|Description|
+|---|---|
|brokerClient_| Configure **all** the proxy's Pulsar Clients. These
configurations are applied after hard coded configuration and before the above
brokerClient configurations named above.|
#### Deprecated parameters of Pulsar proxy
diff --git a/site2/website-next/docs/reference-metrics.md
b/site2/website-next/docs/reference-metrics.md
index a72bba61b56..400a38689e6 100644
--- a/site2/website-next/docs/reference-metrics.md
+++ b/site2/website-next/docs/reference-metrics.md
@@ -182,6 +182,7 @@ All the namespace metrics are labelled with the following
labels:
| pulsar_subscription_delayed | Gauge | The total message batches (entries)
are delayed for dispatching. |
| pulsar_storage_write_latency_le_* | Histogram | The entry rate of a
namespace that the storage write latency is smaller with a given threshold.<br
/> Available thresholds: <br /><ul><li>pulsar_storage_write_latency_le_0_5: <=
0.5ms </li><li>pulsar_storage_write_latency_le_1: <=
1ms</li><li>pulsar_storage_write_latency_le_5: <=
5ms</li><li>pulsar_storage_write_latency_le_10: <=
10ms</li><li>pulsar_storage_write_latency_le_20: <=
20ms</li><li>pulsar_storage_write_latency_le_50: <= 50ms</ [...]
| pulsar_entry_size_le_* | Histogram | The entry rate of a namespace that the
entry size is smaller with a given threshold.<br /> Available thresholds: <br
/><ul><li>pulsar_entry_size_le_128: <= 128 bytes
</li><li>pulsar_entry_size_le_512: <= 512
bytes</li><li>pulsar_entry_size_le_1_kb: <= 1
KB</li><li>pulsar_entry_size_le_2_kb: <= 2
KB</li><li>pulsar_entry_size_le_4_kb: <= 4
KB</li><li>pulsar_entry_size_le_16_kb: <= 16
KB</li><li>pulsar_entry_size_le_100_kb: <= 100 KB</li><li>pulsar_ent [...]
+| pulsar_delayed_delivery_tracker_memory_usage | GAUGE | The total memory size
allocated by `InMemoryDelayedDeliveryTracker` of the namespace owned by this
broker (in bytes). |
#### Replication metrics
@@ -245,6 +246,7 @@ All the topic metrics are labelled with the following
labels:
| pulsar_compaction_latency_le_* | Histogram | The compaction latency with
given quantile. <br /> Available thresholds: <br
/><ul><li>pulsar_compaction_latency_le_0_5: <= 0.5ms
</li><li>pulsar_compaction_latency_le_1: <=
1ms</li><li>pulsar_compaction_latency_le_5: <=
5ms</li><li>pulsar_compaction_latency_le_10: <=
10ms</li><li>pulsar_compaction_latency_le_20: <=
20ms</li><li>pulsar_compaction_latency_le_50: <=
50ms</li><li>pulsar_compaction_latency_le_100: <= 100ms</li><li>pulsar_compact
[...]
| pulsar_compaction_compacted_entries_count | Gauge | The total number of the
compacted entries. |
| pulsar_compaction_compacted_entries_size |Gauge | The total size of the
compacted entries. |
+| pulsar_delayed_delivery_tracker_memory_usage | GAUGE | The total memory size
allocated by `InMemoryDelayedDeliveryTracker` of the topic owned by this broker
(in bytes). |
#### Replication metrics
diff --git a/site2/website-next/versioned_docs/version-2.10.0/about.md
b/site2/website-next/versioned_docs/version-2.10.0/about.md
index 478ac8dd053..69010822119 100644
--- a/site2/website-next/versioned_docs/version-2.10.0/about.md
+++ b/site2/website-next/versioned_docs/version-2.10.0/about.md
@@ -19,12 +19,12 @@ If you’re an experienced coder, review this page to learn
the easiest way to a
## Get Started Now
<BlockLinks>
- <BlockLink title="About Pulsar" url="/docs/concepts-overview/" />
- <BlockLink title="Get Started" url="/docs/getting-started-standalone/" />
- <BlockLink title="Install, Deploy, Upgrade" url="/docs/deploy-aws/" />
- <BlockLink title="Pulsar for Developers" url="/docs/develop-tools/" />
- <BlockLink title="How To" url="/docs/functions-develop/" />
- <BlockLink title="References" url="/docs/reference-terminology/" />
+ <BlockLink title="About Pulsar" url="/docs/2.10.0/concepts-overview/" />
+ <BlockLink title="Get Started"
url="/docs/2.10.0/getting-started-standalone/" />
+ <BlockLink title="Install, Deploy, Upgrade" url="/docs/2.10.0/deploy-aws/"
/>
+ <BlockLink title="Pulsar for Developers" url="/docs/2.10.0/develop-tools/"
/>
+ <BlockLink title="How To" url="/docs/2.10.0/functions-develop/" />
+ <BlockLink title="References" url="/docs/2.10.0/reference-terminology/" />
</BlockLinks>
## Navigation
diff --git
a/site2/website-next/versioned_docs/version-2.10.1/reference-configuration.md
b/site2/website-next/versioned_docs/version-2.10.1/reference-configuration.md
index 4df15fdf782..b261317782b 100644
---
a/site2/website-next/versioned_docs/version-2.10.1/reference-configuration.md
+++
b/site2/website-next/versioned_docs/version-2.10.1/reference-configuration.md
@@ -378,6 +378,20 @@ brokerServiceCompactionThresholdInBytes|If the estimated
backlog size is greater
| strictBookieAffinityEnabled | Enable or disable the strict bookie isolation
strategy. If enabled, <br /> - `bookie-ensemble` first tries to choose bookies
that belong to a namespace's affinity group. If the number of bookies is not
enough, then the rest bookies are chosen. <br /> - If namespace has no affinity
group, `bookie-ensemble` only chooses bookies that belong to no region. If the
number of bookies is not enough, `BKNotEnoughBookiesException` is thrown.|
false |
|narExtractionDirectory | The extraction directory of the nar package. <br
/>Available for Protocol Handler, Additional Servlets, Entry Filter,
Offloaders, Broker Interceptor. | System.getProperty("java.io.tmpdir") |
+#### Configuration override for clients internal to broker
+
+It's possible to configure some clients by using the appropriate prefix.
+
+|Prefix|Description|
+|---|---|
+|brokerClient_| Configure **all** the broker's Pulsar Clients and Pulsar Admin
Clients. These configurations are applied after hard coded configuration and
before the above broker client configurations named above.|
+|bookkeeper_| Configure the broker's BookKeeper clients used by managed
ledgers and the BookkeeperPackagesStorage bookkeeper client. Takes precedence
over most other configuration values.|
+
+::: Note
+
+When running the function worker within the broker, these prefixed
configurations do not apply to any of those clients. You must configure those
clients using the `functions_worker.yml` file.
+
+:::
#### Deprecated parameters of Broker
The following parameters have been deprecated in the `conf/broker.conf` file.
@@ -747,6 +761,14 @@ The following parameters have been deprecated in the
`conf/standalone.conf` file
|tlsKeyFilePath |||
|tlsTrustCertsFilePath|||
+#### Configuration Override For Clients Internal to WebSocket
+
+It's possible to configure some clients by using the appropriate prefix.
+
+|Prefix|Description|
+|---|---|
+|brokerClient_| Configure **all** the broker's Pulsar Clients. These
configurations are applied after hard coded configuration and before the above
brokerClient configurations named above.|
+
#### Deprecated parameters of WebSocket
The following parameters have been deprecated in the `conf/websocket.conf`
file.
@@ -813,6 +835,14 @@ The [Pulsar
proxy](concepts-architecture-overview.md#pulsar-proxy) can be config
| numIOThreads | Number of threads used for Netty IO. | 2 *
Runtime.getRuntime().availableProcessors() |
| numAcceptorThreads | Number of threads used for Netty Acceptor. | 1 |
+#### Configuration Override For Clients Internal to Proxy
+
+It's possible to configure some clients by using the appropriate prefix.
+
+|Prefix|Description|
+|---|---|
+|brokerClient_| Configure **all** the proxy's Pulsar Clients. These
configurations are applied after hard coded configuration and before the above
brokerClient configurations named above.|
+
#### Deprecated parameters of Pulsar proxy
The following parameters have been deprecated in the `conf/proxy.conf` file.
