Skip to content
Merged
  •  
  •  
  •  
2 changes: 1 addition & 1 deletion site2/docs/cookbooks-tiered-storage.md
Original file line number Diff line number Diff line change
Expand Up @@ -306,5 +306,5 @@ Error in offload
null

Reason: Error offloading: org.apache.bookkeeper.mledger.ManagedLedgerException: java.util.concurrent.CompletionException: com.amazonaws.services.s3.model.AmazonS3Exception: Anonymous users cannot initiate multipart uploads. Please authenticate. (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: 798758DE3F1776DF; S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=), S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=
````
```

2 changes: 1 addition & 1 deletion site2/docs/tiered-storage-aliyun.md
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,7 @@ For individual topics, you can trigger the Aliyun OSS offloader manually using o
null

Reason: Error offloading: org.apache.bookkeeper.mledger.ManagedLedgerException: java.util.concurrent.CompletionException: com.amazonaws.services.s3.model.AmazonS3Exception: Anonymous users cannot initiate multipart uploads. Please authenticate. (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: 798758DE3F1776DF; S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=), S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=
````
```

> **Tip**
>
Expand Down
2 changes: 1 addition & 1 deletion site2/docs/tiered-storage-aws.md
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ For individual topics, you can trigger AWS S3 offloader manually using one of th
null

Reason: Error offloading: org.apache.bookkeeper.mledger.ManagedLedgerException: java.util.concurrent.CompletionException: com.amazonaws.services.s3.model.AmazonS3Exception: Anonymous users cannot initiate multipart uploads. Please authenticate. (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: 798758DE3F1776DF; S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=), S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=
````
```

> #### Tip
>
Expand Down
2 changes: 1 addition & 1 deletion site2/docs/tiered-storage-azure.md
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ For individual topics, you can trigger Azure BlobStore offloader manually using
null

Reason: Error offloading: org.apache.bookkeeper.mledger.ManagedLedgerException:
````
```

> #### Tip
>
Expand Down
2 changes: 1 addition & 1 deletion site2/docs/tiered-storage-filesystem.md
Original file line number Diff line number Diff line change
Expand Up @@ -257,7 +257,7 @@ To trigger via CLI tools, you need to specify the maximum amount of data (thresh
null

Reason: Error offloading: org.apache.bookkeeper.mledger.ManagedLedgerException: java.util.concurrent.CompletionException: com.amazonaws.services.s3.model.AmazonS3Exception: Anonymous users cannot initiate multipart uploads. Please authenticate. (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: 798758DE3F1776DF; S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=), S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=
````
```

> #### Tip
>
Expand Down
2 changes: 1 addition & 1 deletion site2/docs/tiered-storage-gcs.md
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ For individual topics, you can trigger GCS offloader manually using one of the f
null

Reason: Error offloading: org.apache.bookkeeper.mledger.ManagedLedgerException: java.util.concurrent.CompletionException: com.amazonaws.services.s3.model.AmazonS3Exception: Anonymous users cannot initiate multipart uploads. Please authenticate. (Service: Amazon S3; Status Code: 403; Error Code: AccessDenied; Request ID: 798758DE3F1776DF; S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=), S3 Extended Request ID: dhBFz/lZm1oiG/oBEepeNlhrtsDlzoOhocuYMpKihQGXe6EG8puRGOkK6UwqzVrMXTWBxxHcS+g=
````
```

> #### Tip
>
Expand Down
2 changes: 1 addition & 1 deletion site2/website-next/docs/adaptors-kafka.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
---
id: adaptors-kafka
title: Pulsar adaptor for Apache Kafka
sidebar_label: Kafka client wrapper
sidebar_label: "Kafka client wrapper"
---

import Tabs from '@theme/Tabs';
Expand Down
5 changes: 3 additions & 2 deletions site2/website-next/docs/adaptors-spark.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
---
id: adaptors-spark
title: Pulsar adaptor for Apache Spark
sidebar_label: Apache Spark
sidebar_label: "Apache Spark"
---

import Tabs from '@theme/Tabs';
Expand Down Expand Up @@ -90,4 +90,5 @@ SparkStreamingPulsarReceiver pulsarReceiver = new SparkStreamingPulsarReceiver(
pulsarConf,
new AuthenticationToken("token:<secret-JWT-token>"));

```
```

2 changes: 1 addition & 1 deletion site2/website-next/docs/adaptors-storm.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
---
id: adaptors-storm
title: Pulsar adaptor for Apache Storm
sidebar_label: Apache Storm
sidebar_label: "Apache Storm"
---

import Tabs from '@theme/Tabs';
Expand Down
10 changes: 9 additions & 1 deletion site2/website-next/docs/admin-api-brokers.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
---
id: admin-api-brokers
title: Managing Brokers
sidebar_label: Brokers
sidebar_label: "Brokers"
---

import Tabs from '@theme/Tabs';
Expand Down Expand Up @@ -64,6 +64,7 @@ $ pulsar-admin brokers list use
```

```

broker1.use.org.com:8080

```
Expand Down Expand Up @@ -115,6 +116,7 @@ $ pulsar-admin brokers leader-broker
```

```

BrokerInfo(serviceUrl=broker1.use.org.com:8080)

```
Expand All @@ -132,6 +134,7 @@ BrokerInfo(serviceUrl=broker1.use.org.com:8080)
admin.brokers().getLeaderBroker()

```

For the detail of the code above, see [here](https://github.com/apache/pulsar/blob/master/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BrokersImpl.java#L80)

</TabItem>
Expand Down Expand Up @@ -178,6 +181,7 @@ $ pulsar-admin brokers namespaces use \
}

```

</TabItem>
<TabItem value="REST API">

Expand All @@ -191,6 +195,7 @@ $ pulsar-admin brokers namespaces use \
admin.brokers().getOwnedNamespaces(cluster,brokerUrl);

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -245,6 +250,7 @@ $ pulsar-admin brokers update-dynamic-config --config brokerShutdownTimeoutMs --
admin.brokers().updateDynamicConfiguration(configName, configValue);

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -290,6 +296,7 @@ brokerShutdownTimeoutMs
admin.brokers().getDynamicConfigurationNames();

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -336,6 +343,7 @@ brokerShutdownTimeoutMs:100
admin.brokers().getAllDynamicConfigurations();

```

</TabItem>

</Tabs>
10 changes: 9 additions & 1 deletion site2/website-next/docs/admin-api-clusters.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
---
id: admin-api-clusters
title: Managing Clusters
sidebar_label: Clusters
sidebar_label: "Clusters"
---

import Tabs from '@theme/Tabs';
Expand Down Expand Up @@ -82,6 +82,7 @@ ClusterData clusterData = new ClusterData(
admin.clusters().createCluster(clusterName, clusterData);

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -172,6 +173,7 @@ $ pulsar-admin clusters get cluster-1
admin.clusters().getCluster(clusterName);

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -227,6 +229,7 @@ ClusterData clusterData = new ClusterData(
admin.clusters().updateCluster(clusterName, clusterData);

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -256,6 +259,7 @@ Clusters can be deleted from a Pulsar [instance](reference-terminology.md#instan
Use the [`delete`](reference-pulsar-admin.md#clusters-delete) subcommand and specify the name of the cluster.

```

$ pulsar-admin clusters delete cluster-1

```
Expand All @@ -273,6 +277,7 @@ $ pulsar-admin clusters delete cluster-1
admin.clusters().deleteCluster(clusterName);

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -322,6 +327,7 @@ cluster-2
admin.clusters().getClusters();

```

</TabItem>

</Tabs>
Expand Down Expand Up @@ -351,6 +357,7 @@ Peer clusters can be configured for a given cluster in a Pulsar [instance](refer
Use the [`update-peer-clusters`](reference-pulsar-admin.md#clusters-update-peer-clusters) subcommand and specify the list of peer-cluster names.

```

$ pulsar-admin update-peer-clusters cluster-1 --peer-clusters cluster-2

```
Expand All @@ -368,6 +375,7 @@ $ pulsar-admin update-peer-clusters cluster-1 --peer-clusters cluster-2
admin.clusters().updatePeerClusterNames(clusterName, peerClusterList);

```

</TabItem>

</Tabs>
Loading