Merge pull request #2 from alexandrebrilhante/develop

Merge develop into master
alexandrebrilhante · Jun 29, 2024 · d82ef01 · d82ef01
2 parents 549999e + d24f030
commit d82ef01
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -43,7 +43,7 @@ CREATE TABLE pulsar_cassandra_sink (key text PRIMARY KEY, col text);
 ```bash
 pulsar-daemon start standalone
 
-pulsar-admin schemas upload test -f $PWD/pulsar/connectors/avro-schema
+pulsar-admin schemas upload $PULSAR_TOPIC_NAME -f $PWD/pulsar/connectors/schema.avsc
 
 pulsar-admin sinks create \
     --archive $PWD/pulsar/connectors/cassandra/pulsar-io-cassandra-3.2.2.nar \
@@ -67,7 +67,7 @@ CREATE TABLE IF NOT EXISTS pulsar_postgres_jdbc_sink (
 ```bash
 pulsar-daemon start standalone
 
-pulsar-admin schemas upload test -f $PWD/pulsar/connectors/avro-schema
+pulsar-admin schemas upload $PULSAR_TOPIC_NAME -f $PWD/pulsar/connectors/schema.avsc
 
 pulsar-admin sinks create \
     --archive $PWD/pulsar/connectors/postgres/pulsar-io-jdbc-postgres-3.2.2.nar \
@@ -91,7 +91,7 @@ CREATE TABLE IF NOT EXISTS pulsar_questdb_sink (
 ```bash
 pulsar-daemon start standalone
 
-pulsar-admin schemas upload test -f $PWD/pulsar/connectors/avro-schema
+pulsar-admin schemas upload $PULSAR_TOPIC_NAME -f $PWD/pulsar/connectors/schema.avsc
 
 pulsar-admin sinks create \
     --archive $PWD/pulsar/connectors/postgres/pulsar-io-jdbc-postgres-3.2.2.nar \

diff --git a/scripts/run_cassandra.sh b/scripts/run_cassandra.sh
@@ -2,7 +2,7 @@
 
 pulsar-daemon start standalone
 
-pulsar-admin schemas upload test -f $PWD/pulsar/connectors/avro-schema
+pulsar-admin schemas upload $PULSAR_TOPIC_NAME -f $PWD/pulsar/connectors/schema.avsc
 
 pulsar-admin sinks create \
     --archive $PWD/pulsar/connectors/cassandra/pulsar-io-cassandra-3.2.2.nar \

diff --git a/scripts/run_postgres.sh b/scripts/run_postgres.sh
@@ -2,7 +2,7 @@
 
 pulsar-daemon start standalone
 
-pulsar-admin schemas upload test -f $PWD/pulsar/connectors/avro-schema
+pulsar-admin schemas upload $PULSAR_TOPIC_NAME -f $PWD/pulsar/connectors/schema.avsc
 
 pulsar-admin sinks create \
     --archive $PWD/pulsar/connectors/postgres/pulsar-io-jdbc-postgres-3.2.2.nar \

diff --git a/scripts/run_questdb.sh b/scripts/run_questdb.sh
@@ -2,7 +2,7 @@
 
 pulsar-daemon start standalone
 
-pulsar-admin schemas upload test -f $PWD/pulsar/connectors/avro-schema
+pulsar-admin schemas upload $PULSAR_TOPIC_NAME -f $PWD/pulsar/connectors/schema.avsc
 
 pulsar-admin sinks create \
     --archive $PWD/pulsar/connectors/postgres/pulsar-io-jdbc-postgres-3.2.2.nar \