Deleting the DataStax Apache Pulsar™ Connector

To completely remove the DataStax Apache Pulsar™ Connector:

  1. Delete any sinks associated with the DataStax Apache Pulsar™ Connector:

    bin/pulsar-admin sinks delete --name sink_name --namespace sink_namespace --tenant sink_tenant


    • name - The name of the Pulsar sink.

    • namespace - The namespace in which the sink resides.

    • sink_tenant - The tenant name associated with the sink.

      Example - delete the cass-sink-kv

      bin/pulsar-admin sinks delete \
          --tenant public \
          --namespace default \
          --name dse-sink-kv
      "Deleted successfully"
  2. Stop the Pulsar service:

    bin/pulsar-daemon stop standalone
    doing stop standalone ...
    stopping standalone
    Shutdown is in progress... Please wait...
    Shutdown is in progress... Please wait...
    Shutdown completed.
  3. Remove the DataStax Apache Pulsar™ Connector from the connectors directory:

    rm connectors/cassandra-enhanced-pulsar-sink-1.4.0.nar
  4. Restart the Pulsar service:

    bin/pulsar-daemon start standalone
    doing start standalone ...
    starting standalone, logging to /Users/john.francis/apache-pulsar-2.7.0/logs/pulsar-standalone-jfrancis-rmbp15.log
    Note: Set immediateFlush to true in conf/log4j2.yaml will guarantee the logging event is flushing to disk immediately. The default behavior is switched off due to performance considerations.
    [AppClassLoader@18b4aac2] info AspectJ Weaver Version 1.9.2 built on Wednesday Oct 24, 2018 at 15:43:33 GMT
    [AppClassLoader@18b4aac2] info register classloader sun.misc.Launcher$AppClassLoader@18b4aac2
    [AppClassLoader@18b4aac2] info using configuration file:/Users/john.francis/apache-pulsar-2.7.0/lib/org.apache.pulsar-pulsar-zookeeper-2.7.0.jar!/META-INF/aop.xml
    [AppClassLoader@18b4aac2] info using configuration file:/Users/john.francis/apache-pulsar-2.7.0/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.7.0.jar!/META-INF/aop.xml
    [AppClassLoader@18b4aac2] info register aspect org.apache.pulsar.zookeeper.FinalRequestProcessorAspect
    [AppClassLoader@18b4aac2] info register aspect org.apache.pulsar.zookeeper.ZooKeeperServerAspect
    [AppClassLoader@18b4aac2] info register aspect

Was this helpful?

Give Feedback

How can we improve the documentation?

© 2024 DataStax | Privacy policy | Terms of use

Apache, Apache Cassandra, Cassandra, Apache Tomcat, Tomcat, Apache Lucene, Apache Solr, Apache Hadoop, Hadoop, Apache Pulsar, Pulsar, Apache Spark, Spark, Apache TinkerPop, TinkerPop, Apache Kafka and Kafka are either registered trademarks or trademarks of the Apache Software Foundation or its subsidiaries in Canada, the United States and/or other countries. Kubernetes is the registered trademark of the Linux Foundation.

General Inquiries: +1 (650) 389-6000,