Skip to content

Commit

Permalink
Fix README commands
Browse files Browse the repository at this point in the history
  • Loading branch information
Vincent Royer committed May 17, 2021
1 parent f914c87 commit 237fdaf
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion producer-v4-pulsar/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -6,4 +6,4 @@

## Run

export JVM_EXTRA_OPTS="-javaagent:$CDC_HOME/producer-v4-pulsar/build/libs/producer-v4-pulsar-0.1-SNAPSHOT-all.jar"
export JVM_EXTRA_OPTS="-javaagent:$CDC_HOME/producer-v4-pulsar/build/libs/producer-v4-pulsar-0.1.0-SNAPSHOT-all.jar"
8 changes: 4 additions & 4 deletions source-pulsar/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -33,17 +33,17 @@ A Pulsar key-shared subscription ensure all mutations for a given primary key ar
Cassandra source connector:

$PULSAR_HOME/bin/pulsar-admin source localrun \
--archive $CDC_HOME/source-pulsar/build/libs/source-pulsar-0.1-SNAPSHOT.nar \
--archive $CDC_HOME/source-pulsar/build/libs/source-pulsar-0.1.0-SNAPSHOT.nar \
--tenant public \
--namespace default \
--name cassandra-source-1 \
--destination-topic-name data-ks1.table1 \
--source-config '{"contactPoints":"localhost", "loadBalancing.localDc":"datacenter1", "keyspace":"ks1", "table":"table1", "eventsTopic": "persistent://public/default/events-ks1.table1", "eventsSubscriptionName":"sub1", "keyConverter":"com.datastax.oss.pulsar.source.converters.AvroConverter","valueConverter":"com.datastax.oss.pulsar.source.converters.JsonConverter"}'
--source-config '{"contactPoints":"localhost", "loadBalancing.localDc":"datacenter1", "keyspace":"ks1", "table":"table1", "events.topic": "persistent://public/default/events-ks1.table1", "events.subscription.name":"sub1", "key.converter":"com.datastax.oss.pulsar.source.converters.AvroConverter","value.converter":"com.datastax.oss.pulsar.source.converters.AvroConverter"}'

Elasticsearch sink connector:

$PULSAR_HOME/bin/pulsar-admin sinks localrun \
--archive $PULSAR_HOME/pulsar-io/elastic-search/target/pulsar-io-elastic-search-2.8.0-SNAPSHOT.nar \
bin/pulsar-admin sinks localrun \
--archive pulsar-io/elastic-search/target/pulsar-io-elastic-search-2.8.0-SNAPSHOT.nar \
--tenant public \
--namespace default \
--name elasticsearch-ks1-sink \
Expand Down

0 comments on commit 237fdaf

Please sign in to comment.