Skip to content

Commit 7a8b155

Browse files
authored
DOC-5600 Pulsar connector pages (#185)
* bring index, get started, edit * add scb attributes * add sink source pages and nav * fix links * unify connector index, remove curl examples * remove comment * missing attributes * attributes hacks, missing attributes * fix nav * fix link * bring main topic content * unused attributes * change example syntax * fix file type * once more
1 parent 02de4ed commit 7a8b155

29 files changed

Lines changed: 1161 additions & 229 deletions

antora.yml

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,4 +17,16 @@ asciidoc:
1717
starlight-rabbitmq: 'Starlight for RabbitMQ'
1818
pulsar-reg: 'Apache Pulsar(TM)'
1919
pulsar: 'Apache Pulsar'
20-
pulsar-short: 'Pulsar'
20+
pulsar-short: 'Pulsar'
21+
22+
# Required for include::common partials that are shared with Astra Streaming
23+
web-ui: 'Admin Console'
24+
astra: 'Astra'
25+
astra-db: 'Astra DB'
26+
scb: 'Secure Connect Bundle (SCB)'
27+
scb-short: 'SCB'
28+
scb-brief: 'Secure Connect Bundle'
29+
cass-reg: 'Apache Cassandra(R)'
30+
cass: 'Apache Cassandra'
31+
cass-short: 'Cassandra'
32+
debezium-version: '1.7'

modules/ROOT/nav.adoc

Lines changed: 23 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,28 @@
2323
* xref:operations:auth.adoc[]
2424
* xref:operations:functions.adoc[]
2525
* xref:operations:functions-transform.adoc[]
26-
* xref:operations:io-connectors.adoc[]
26+
* I/O connectors
27+
** xref:connectors:index.adoc[]
28+
** Sinks
29+
*** xref:connectors:sinks/astra-db.adoc[]
30+
*** xref:connectors:sinks/cloud-storage.adoc[]
31+
*** xref:connectors:sinks/elastic-search.adoc[]
32+
*** xref:connectors:sinks/google-bigquery.adoc[]
33+
*** xref:connectors:sinks/jdbc-clickhouse.adoc[]
34+
*** xref:connectors:sinks/jdbc-mariadb.adoc[]
35+
*** xref:connectors:sinks/jdbc-postgres.adoc[]
36+
*** xref:connectors:sinks/jdbc-sqllite.adoc[]
37+
*** xref:connectors:sinks/kafka.adoc[]
38+
*** xref:connectors:sinks/kinesis.adoc[]
39+
*** xref:connectors:sinks/snowflake.adoc[]
40+
** Sources
41+
*** xref:connectors:sources/data-generator.adoc[]
42+
*** xref:connectors:sources/debezium-mongodb.adoc[]
43+
*** xref:connectors:sources/debezium-mysql.adoc[]
44+
*** xref:connectors:sources/debezium-oracle.adoc[]
45+
*** xref:connectors:sources/debezium-postgres.adoc[]
46+
*** xref:connectors:sources/debezium-sqlserver.adoc[]
47+
*** xref:connectors:sources/kafka.adoc[]
48+
*** xref:connectors:sources/kinesis.adoc[]
2749
* xref:operations:scale-cluster.adoc[]
2850
* xref:operations:troubleshooting.adoc[]

modules/ROOT/pages/faqs.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ https://github.com/datastax/pulsar-heartbeat[{pulsar-short} Heartbeat] monitors
8181

8282
== What are the features provided by {company} {pulsar} Connector (`pulsar-sink`) that are not supported in `kafka-sink`?
8383

84-
The https://pulsar.apache.org/docs/en/io-overview/[{pulsar-short} IO framework] provides many features that are not possible in Kafka, and has different compression formats and auth/security features. The features are handled by {pulsar-short}. For more, see xref:operations:io-connectors.adoc[Luna Streaming IO Connectors].
84+
The https://pulsar.apache.org/docs/en/io-overview/[{pulsar-short} IO framework] provides many features that are not possible in Kafka, and has different compression formats and auth/security features. The features are handled by {pulsar-short}. For more, see xref:connectors:index.adoc[Luna Streaming IO Connectors].
8585

8686
The {company} {pulsar} Connector allows single-record acknowledgement and negative acknowledgements.
8787

modules/ROOT/pages/index.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ In addition to the distribution of https://pulsar.apache.org/en/versions/[{pulsa
1717

1818
* A xref:install-upgrade:quickstart-helm-installs.adoc[Helm chart] that deploys and manages {pulsar-short} on your current CNCF-conformant Kubernetes infrastructure
1919

20-
* Cassandra, Elastic, Kinesis, Kafka, and JDBC xref:operations:io-connectors.adoc[connectors]
20+
* Cassandra, Elastic, Kinesis, Kafka, and JDBC xref:connectors:index.adoc[connectors]
2121

2222
* The xref:components:starlight.adoc[Starlight suite of {pulsar-short} protocol handlers for Kafka, RabbitMQ, and JMS]
2323

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
To update a connector, pass the new configuration definition to the connector.
2+
For example, if you created the connector with a configuration file, you can pass an updated configuration file.
3+
4+
You can include the entire configuration or only the properties that you want to change.
5+
Additionally, some properties can be modified with specific arguments, such as `--parallelism`.
6+
7+
To get the current configuration, see xref:connectors:index.adoc#get-sink-connector-configuration-data[Get sink connector configuration data].
8+
9+
[source,shell,subs="+attributes"]
10+
----
11+
./bin/pulsar-admin sinks update \
12+
--sink-type {connectorType} \
13+
--name "$SINK_NAME" \
14+
--inputs "persistent://$TENANT/$NAMESPACE/$TOPIC" \
15+
--tenant "$TENANT" \
16+
--parallelism 2
17+
----
Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
. Optional: If you are using the `pulsar-admin` CLI, set the following commonly-used environment variables:
2+
+
3+
[source,shell,subs="+quotes"]
4+
----
5+
export TENANT="**TENANT_NAME**"
6+
export TOPIC="**INPUT_TOPIC_NAME**"
7+
export NAMESPACE="**NAMESPACE_NAME**"
8+
export SINK_NAME="**SINK_CONNECTOR_UNIQUE_NAME**"
9+
----
10+
+
11+
`**SINK_NAME**` is the name for your new sink connector.
12+
{company} recommends a memorable, human-readable name that summarizes the connector's purpose.
13+
For example: `{connectorType}-sink-prod-us-east-1`.
14+
15+
. Create the connector using JSON-formatted connector configuration data.
16+
You can pass the configuration directly or with a configuration file.
17+
+
18+
[source,shell,subs="+attributes"]
19+
----
20+
./bin/pulsar-admin sinks create \
21+
--sink-type {connectorType} \
22+
--name "$SINK_NAME" \
23+
--inputs "persistent://$TENANT/$NAMESPACE/$TOPIC" \
24+
--tenant "$TENANT" \
25+
--sink-config-file configs.json
26+
----
27+
+
28+
.Example configuration data structure
29+
[source,json]
30+
----
31+
include::common:streaming:example$connectors/sinks/{connectorType}/sample-data.json[]
32+
----
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
To update a connector, pass the new configuration definition to the connector.
2+
For example, if you created the connector with a configuration file, you can pass an updated configuration file.
3+
4+
You can include the entire configuration or only the properties that you want to change.
5+
Additionally, some properties can be modified with specific arguments, such as `--parallelism`.
6+
7+
To get the current configuration, see xref:connectors:index.adoc#get-source-connector-configuration-data[Get source connector configuration data].
8+
9+
[source,shell,subs="+attributes"]
10+
----
11+
./bin/pulsar-admin sources update \
12+
--source-type {connectorType} \
13+
--name "$SOURCE_NAME" \
14+
--destination-topic-name "persistent://$TENANT/$NAMESPACE/$TOPIC" \
15+
--tenant "$TENANT" \
16+
--parallelism 2
17+
----
Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
. Optional: If you are using the `pulsar-admin` CLI, set the following commonly-used environment variables:
2+
+
3+
[source,shell,subs="+quotes"]
4+
----
5+
export TENANT="**TENANT_NAME**"
6+
export TOPIC="**OUTPUT_TOPIC_NAME**"
7+
export NAMESPACE="**NAMESPACE_NAME**"
8+
export SOURCE_NAME="**SOURCE_CONNECTOR_UNIQUE_NAME**"
9+
----
10+
+
11+
`**SOURCE_NAME**` is the name for your new source connector.
12+
{company} recommends a memorable, human-readable name that summarizes the connector's purpose.
13+
For example: `{connectorType}-source-prod-us-east-1`.
14+
15+
. Create the connector using JSON-formatted connector configuration data.
16+
You can pass the configuration directly or with a configuration file.
17+
+
18+
[source,shell,subs="+attributes"]
19+
----
20+
./bin/pulsar-admin sources create \
21+
--source-type {connectorType} \
22+
--name "$SOURCE_NAME" \
23+
--destination-topic-name "persistent://$TENANT/$NAMESPACE/$TOPIC" \
24+
--tenant "$TENANT" \
25+
--source-config-file configs.json
26+
----
27+
+
28+
.Example configuration data structure
29+
[source,json]
30+
----
31+
include::common:streaming:example$connectors/sources/{connectorType}/sample-data.json[]
32+
----

0 commit comments

Comments
 (0)