Update nav format

Author: eric-schneider

modules/ROOT/nav.adoc

@@ -1,65 +1,59 @@
-* Processing Data
-** Change Data Capture
-*** xref:streaming-learning:use-cases-architectures:change-data-capture/index.adoc[Overview]
-*** xref:streaming-learning:use-cases-architectures:change-data-capture/table-schema-evolution.adoc[Table schema evolution]
-*** xref:streaming-learning:use-cases-architectures:change-data-capture/consuming-change-data.adoc[Consuming change data]
-*** xref:streaming-learning:use-cases-architectures:change-data-capture/questions-and-patterns.adoc[Questions and patterns]
-
-** xref:streaming-learning:use-cases-architectures:real-time-data-pipeline/index.adoc[Data Pipelines]
-
-* Migrating to Apache Pulsar
-
-** xref:streaming-learning:use-cases-architectures:starlight/kafka/index.adoc[Starlight for Kafka]
-** xref:streaming-learning:use-cases-architectures:starlight/rabbitmq/index.adoc[Starlight for RabbitMQ]
-** xref:streaming-learning:use-cases-architectures:starlight/jms/index.adoc[Starlight for JMS]
-
-* APIs & References
-
-** Connectors
-
-*** xref:streaming-learning:pulsar-io:connectors/index.adoc[Connector Overview]
-
-*** Sources
-**** xref:streaming-learning:pulsar-io:connectors/sources/data-generator.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/debezium-mongodb.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/debezium-mysql.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/debezium-oracle.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/debezium-postgres.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/debezium-sqlserver.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/kafka.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sources/kinesis.adoc[]
-
-*** Sinks
-**** xref:streaming-learning:pulsar-io:connectors/sinks/astra-db.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/cloud-storage.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/elastic-search.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/google-bigquery.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/jdbc-postgres.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/jdbc-mariadb.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/jdbc-clickhouse.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/jdbc-sqllite.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/kafka.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/kinesis.adoc[]
-**** xref:streaming-learning:pulsar-io:connectors/sinks/snowflake.adoc[]
-
-** xref:streaming-learning:functions:astream-functions.adoc[Pulsar Functions]
-
-** Transformation Functions
-
-*** xref:streaming-learning:functions:index.adoc[Overview]
-*** xref:streaming-learning:functions:cast.adoc[]
-*** xref:streaming-learning:functions:compute.adoc[]
-*** xref:streaming-learning:functions:drop.adoc[]
-*** xref:streaming-learning:functions:flatten.adoc[]
-*** xref:streaming-learning:functions:merge-key-value.adoc[]
-*** xref:streaming-learning:functions:unwrap-key-value.adoc[]
-*** xref:streaming-learning:functions:deploy-in-sink.adoc[]
-*** xref:streaming-learning:functions:drop-fields.adoc[]
-
-** Topic Subscriptions
-
-*** xref:streaming-learning:subscriptions:index.adoc[Overview]
-*** xref:streaming-learning:subscriptions:astream-subscriptions-exclusive.adoc[Exclusive]
-*** xref:streaming-learning:subscriptions:astream-subscriptions-failover.adoc[Failover]
-*** xref:streaming-learning:subscriptions:astream-subscriptions-shared.adoc[Shared]
-*** xref:streaming-learning:subscriptions:astream-subscriptions-keyshared.adoc[Key Shared]
+.Processing data
+* Change Data Capture (CDC)
+** xref:use-cases-architectures:change-data-capture/index.adoc[]
+** xref:use-cases-architectures:change-data-capture/table-schema-evolution.adoc[]
+** xref:use-cases-architectures:change-data-capture/consuming-change-data.adoc[]
+** xref:use-cases-architectures:change-data-capture/questions-and-patterns.adoc[]
+* Data pipelines
+** xref:use-cases-architectures:real-time-data-pipeline/index.adoc[]
+** xref:use-cases-architectures:real-time-data-pipeline/01-create-astra-objects.adoc[]
+** xref:use-cases-architectures:real-time-data-pipeline/02-create-decodable-objects.adoc[]
+** xref:use-cases-architectures:real-time-data-pipeline/03-put-it-all-together.adoc[]
+** xref:use-cases-architectures:real-time-data-pipeline/04-debugging-and-clean-up.adoc[]
+
+.Migrating to Apache Pulsar
+* xref:use-cases-architectures:starlight/kafka/index.adoc[]
+* xref:use-cases-architectures:starlight/rabbitmq/index.adoc[]
+* xref:use-cases-architectures:starlight/jms/index.adoc[]
+
+.APIs & References
+* Connectors
+** xref:pulsar-io:connectors/index.adoc[]
+** Sources
+*** xref:pulsar-io:connectors/sources/data-generator.adoc[]
+*** xref:pulsar-io:connectors/sources/debezium-mongodb.adoc[]
+*** xref:pulsar-io:connectors/sources/debezium-mysql.adoc[]
+*** xref:pulsar-io:connectors/sources/debezium-oracle.adoc[]
+*** xref:pulsar-io:connectors/sources/debezium-postgres.adoc[]
+*** xref:pulsar-io:connectors/sources/debezium-sqlserver.adoc[]
+*** xref:pulsar-io:connectors/sources/kafka.adoc[]
+*** xref:pulsar-io:connectors/sources/kinesis.adoc[]
+** Sinks
+*** xref:pulsar-io:connectors/sinks/astra-db.adoc[]
+*** xref:pulsar-io:connectors/sinks/cloud-storage.adoc[]
+*** xref:pulsar-io:connectors/sinks/elastic-search.adoc[]
+*** xref:pulsar-io:connectors/sinks/google-bigquery.adoc[]
+*** xref:pulsar-io:connectors/sinks/jdbc-postgres.adoc[]
+*** xref:pulsar-io:connectors/sinks/jdbc-mariadb.adoc[]
+*** xref:pulsar-io:connectors/sinks/jdbc-clickhouse.adoc[]
+*** xref:pulsar-io:connectors/sinks/jdbc-sqllite.adoc[]
+*** xref:pulsar-io:connectors/sinks/kafka.adoc[]
+*** xref:pulsar-io:connectors/sinks/kinesis.adoc[]
+*** xref:pulsar-io:connectors/sinks/snowflake.adoc[]
+* xref:functions:astream-functions.adoc[]
+* Transformation Functions
+** xref:functions:index.adoc[]
+** xref:functions:cast.adoc[]
+** xref:functions:compute.adoc[]
+** xref:functions:drop.adoc[]
+** xref:functions:flatten.adoc[]
+** xref:functions:merge-key-value.adoc[]
+** xref:functions:unwrap-key-value.adoc[]
+** xref:functions:deploy-in-sink.adoc[]
+** xref:functions:drop-fields.adoc[]
+* Topic Subscriptions
+** xref:subscriptions:index.adoc[]
+** xref:subscriptions:astream-subscriptions-exclusive.adoc[]
+** xref:subscriptions:astream-subscriptions-failover.adoc[]
+** xref:subscriptions:astream-subscriptions-shared.adoc[]
+** xref:subscriptions:astream-subscriptions-keyshared.adoc[]

modules/functions/pages/astream-functions.adoc

@@ -1,4 +1,5 @@
 = Apache Pulsar Functions
+:navtitle: Pulsar Functions
 :page-tag: astra-streaming,dev,develop,pulsar,java,python
 
 Functions are lightweight compute processes that enable you to process each message received on a topic. You can apply custom logic to that message, transforming or enriching it, and then output it to a different topic.

modules/functions/pages/index.adoc

@@ -1,4 +1,5 @@
 = Transform Functions
+:navtitle: Overview
 
 A Pulsar *transform function* is a low-code implementation of xref:astra-streaming:developing:astream-functions.adoc[Pulsar functions]. +
 Functions receive data from one or more input topics, apply user-supplied processing, and publish the results to another topic. +

modules/pulsar-io/pages/connectors/index.adoc

@@ -1,5 +1,5 @@
 = Connectors
-:navtitle: Pulsar IO Connectors
+:navtitle: Connector Overview
 :page-tag: connectors,sinks,sources,astra-streaming,dev,develop,pulsar,go
 
 {product_name} offers fully-managed Apache Pulsar™ connectors.

modules/subscriptions/pages/astream-subscriptions-exclusive.adoc

@@ -1,4 +1,5 @@
 = Exclusive subscriptions in Pulsar
+:navtitle: Exclusive
 :page-tag: pulsar-subscriptions,quickstart,admin,dev,pulsar
 
 *Subscriptions* in Pulsar describe which consumers are consuming data from a topic and how they want to consume that data. +
@@ -17,9 +18,9 @@ This example uses the `pulsarConsumer` object in `SimplePulsarConsumer.java` bel
 [source,java]
 ----
 pulsarConsumer = pulsarClient.newConsumer(Schema.JSON(DemoBean.class))
-    .topic("persistent://" 
-            + conf.getTenantName() + "/" 
-            + conf.getNamespace() + "/" 
+    .topic("persistent://"
+            + conf.getTenantName() + "/"
+            + conf.getNamespace() + "/"
             + conf.getTopicName())
     .startMessageIdInclusive()
     .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
@@ -31,7 +32,7 @@ pulsarConsumer = pulsarClient.newConsumer(Schema.JSON(DemoBean.class))
 ====
 Pulsar creates an exclusive subscription by default when no `subscriptionType` is declared.
 ====
- 
+
 . Open the `pulsar-subscription-example` repo in the IDE of your choice and run `SimplePulsarConsumer.java` to begin consuming messages. +
 The confirmation message and a cursor appear to indicate the consumer is ready.
 +
@@ -42,7 +43,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://<tenant_name>/<namespace>/in][SimplePulsarConsumer] Subscribed to topic on <service_url> -- consumer: 0
 ----
 
-. In a new terminal window, run `SimplePulsarProducer.java` to begin producing messages. 
+. In a new terminal window, run `SimplePulsarProducer.java` to begin producing messages.
 +
 [source,bash]
 ----
@@ -51,7 +52,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [main] INFO com.datastax.pulsar.SimplePulsarProducer - Message 68306175 sent
 ----
 
-. The consumer begins consuming the produced messages. 
+. The consumer begins consuming the produced messages.
 +
 [source,bash]
 ----
@@ -60,7 +61,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [main] INFO com.datastax.pulsar.SimplePulsarConsumer - Message received: {"show_id":68306175,"cast":"LeBron James, Anthony Davis, Kyrie Irving, Damian Lillard, Klay Thompson...","country":"United States","date_added":"July 16, 2021","description":"NBA superstar LeBron James teams up with Bugs Bunny and the rest of the Looney Tunes for this long-awaited sequel.","director":"Malcolm D. Lee","duration":"120 min","listed_in":"Animation, Adventure, Comedy","rating":"PG","release_year":2021,"title":"Space Jam: A New Legacy","type":"Movie"}
 ----
 
-. Open a new terminal window and try to run `SimplePulsarConsumer.java`. 
+. Open a new terminal window and try to run `SimplePulsarConsumer.java`.
 +
 [source,bash]
 ----

modules/subscriptions/pages/astream-subscriptions-failover.adoc

@@ -1,4 +1,5 @@
 = Failover subscriptions in Pulsar
+:navtitle: Failover
 :page-tag: pulsar-subscriptions,quickstart,admin,dev,pulsar
 
 *Subscriptions* in Pulsar describe which consumers are consuming data from a topic and how they want to consume that data. +
@@ -13,14 +14,14 @@ include::partial$subscription-prereq.adoc[]
 [#example]
 == Failover subscription example
 
-To try out a Pulsar failover subscription, add `.subscriptionType(SubscriptionType.Failover)` to the `pulsarConsumer` in `SimplePulsarConsumer.java`. 
+To try out a Pulsar failover subscription, add `.subscriptionType(SubscriptionType.Failover)` to the `pulsarConsumer` in `SimplePulsarConsumer.java`.
 
 [source,java]
 ----
 pulsarConsumer = pulsarClient.newConsumer(Schema.JSON(DemoBean.class))
-    .topic("persistent://" 
-        + conf.getTenantName() + "/" 
-        + conf.getNamespace() + "/" 
+    .topic("persistent://"
+        + conf.getTenantName() + "/"
+        + conf.getNamespace() + "/"
         + conf.getTopicName())
     .startMessageIdInclusive()
     .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
@@ -40,7 +41,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://<tenant_name>/<namespace>/in][SimplePulsarConsumer] Subscribed to topic on <service_url> -- consumer: 0
 ----
 
-. In a new terminal window, run `SimplePulsarProducer.java` to begin producing messages. 
+. In a new terminal window, run `SimplePulsarProducer.java` to begin producing messages.
 +
 [source,bash]
 ----
@@ -52,7 +53,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [main] INFO com.datastax.pulsar.SimplePulsarProducer - Message 42372149 sent
 ----
 
-. The primary consumer begins consuming messages. 
+. The primary consumer begins consuming messages.
 +
 [source,bash]
 ----
@@ -75,7 +76,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 
 === Failover subscription video
 
-Follow along with this video from our *Five Minutes About Pulsar* series to see failover subscriptions in action. 
+Follow along with this video from our *Five Minutes About Pulsar* series to see failover subscriptions in action.
 
 video::ckB87OLs5eM[youtube, list=PL2g2h-wyI4SqeKH16czlcQ5x4Q_z-X7_m, height=445px,width=100%]
 

modules/subscriptions/pages/astream-subscriptions-keyshared.adoc

@@ -1,4 +1,5 @@
 = Key_Shared subscriptions in Pulsar
+:navtitle: Key Shared
 :page-tag: pulsar-subscriptions,quickstart,admin,dev,pulsar
 
 *Subscriptions* in Pulsar describe which consumers are consuming data from a topic and how they want to consume that data. +
@@ -8,7 +9,7 @@ Pulsar's xref:astream-subscriptions-shared.adoc[shared subscription] model trade
 *Keys* are generated with *hashing*, which converts arbitrary values like "topic-name" or JSON blobs into fixed integer values. These hashed values are then assigned to subscribed consumers in one of two ways:
 
 * *Auto hash* - uses *consistent hashing* to balance range values across available consumers, without requiring manual setup of hash ranges.
-* *Sticky hash* - the client manually assigns consumer range values. All hashes within a configured range go to one consumer. 
+* *Sticky hash* - the client manually assigns consumer range values. All hashes within a configured range go to one consumer.
 
 This document explains how to use Pulsar's Key_Shared subscription model to manage your topic consumption.
 
@@ -18,28 +19,28 @@ include::partial$subscription-prereq.adoc[]
 == Key_Shared subscription example
 
 To try out a Pulsar Key_Shared subscription, add `.subscriptionType(SubscriptionType.Key_Shared)` to the `pulsarConsumer` in `SimplePulsarConsumer.java`. +
-You must also tell Pulsar what `keySharedPolicy` this subscription will use. The example below uses the auto-hashing `keySharedPolicy`. 
+You must also tell Pulsar what `keySharedPolicy` this subscription will use. The example below uses the auto-hashing `keySharedPolicy`.
 
 [source,java]
 ----
 pulsarConsumer = pulsarClient.newConsumer(Schema.JSON(DemoBean.class))
-    .topic("persistent://" 
-        + conf.getTenantName() + "/" 
-        + conf.getNamespace() + "/" 
+    .topic("persistent://"
+        + conf.getTenantName() + "/"
+        + conf.getNamespace() + "/"
         + conf.getTopicName())
     .startMessageIdInclusive()
     .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
     .subscriptionName("SimplePulsarConsumer")
     .subscriptionType(SubscriptionType.Key_Shared)
     .keySharedPolicy(KeySharedPolicy.autoSplitHashRange())
-    .subscribe();  
+    .subscribe();
 ----
 
-Running multiple consumers with auto-hashing balances the messaging load across all available consumers. 
+Running multiple consumers with auto-hashing balances the messaging load across all available consumers.
 
 === Manually set stickyHashRange
 
-You can manually set a hash range with `KeySharedPolicy.stickyHashRange()`. 
+You can manually set a hash range with `KeySharedPolicy.stickyHashRange()`.
 
 To test out sticky hashed Key_Shared subscriptions, you need to first import some additional classes.
 
@@ -66,9 +67,9 @@ import org.apache.pulsar.client.api.HashingScheme;
 ----
 pulsarProducer = pulsarClient
     .newProducer(Schema.JSON(DemoBean.class))
-    .topic("persistent://" 
-                + conf.getTenantName() + "/" 
-                + conf.getNamespace() + "/" 
+    .topic("persistent://"
+                + conf.getTenantName() + "/"
+                + conf.getNamespace() + "/"
                 + conf.getTopicName())
     .batcherBuilder(BatcherBuilder.KEY_BASED)
     .hashingScheme(HashingScheme.JavaStringHash)
@@ -93,7 +94,7 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://<tenant_name>/<namespace>/in][SimplePulsarConsumer] Subscribed to topic on <service_url> -- consumer: 0
 ----
 
-. In a new terminal window, run `SimplePulsarProducer.java` to begin producing messages. 
+. In a new terminal window, run `SimplePulsarProducer.java` to begin producing messages.
 +
 [source,bash]
 ----
@@ -103,15 +104,15 @@ The confirmation message and a cursor appear to indicate the consumer is ready.
 [main] INFO com.datastax.pulsar.SimplePulsarProducer - Message 57467766 sent
 ----
 
-. The consumer begins receiving messages. 
+. The consumer begins receiving messages.
 +
 [source,bash]
 ----
 [main] INFO com.datastax.pulsar.SimplePulsarConsumer - Message received: {"show_id":55794190,"cast":"LeBron James, Anthony Davis, Kyrie Irving, Damian Lillard, Klay Thompson...","country":"United States","date_added":"July 16, 2021","description":"NBA superstar LeBron James teams up with Bugs Bunny and the rest of the Looney Tunes for this long-awaited sequel.","director":"Malcolm D. Lee","duration":"120 min","listed_in":"Animation, Adventure, Comedy","rating":"PG","release_year":2021,"title":"Space Jam: A New Legacy","type":"Movie"}
 [main] INFO com.datastax.pulsar.SimplePulsarConsumer - Message received: {"show_id":41791865,"cast":"LeBron James, Anthony Davis, Kyrie Irving, Damian Lillard, Klay Thompson...","country":"United States","date_added":"July 16, 2021","description":"NBA superstar LeBron James teams up with Bugs Bunny and the rest of the Looney Tunes for this long-awaited sequel.","director":"Malcolm D. Lee","duration":"120 min","listed_in":"Animation, Adventure, Comedy","rating":"PG","release_year":2021,"title":"Space Jam: A New Legacy","type":"Movie"}
 ----
 
-. Open a new terminal window and try to run `SimplePulsarConsumer.java`. 
+. Open a new terminal window and try to run `SimplePulsarConsumer.java`.
 +
 [source,bash]
 ----