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