bin/pulsar standalone

bin/pulsar-daemon start websocket

docker exec 03ecc2709715 solr delete -c energy

docker exec 03ecc2709715 solr create -c energy

docker exec 03ecc2709715 solr delete -c docs

docker exec 03ecc2709715 solr create -c docs

docker exec 03ecc2709715 solr delete -c jetson

docker exec 03ecc2709715 solr create -c jetson

# example build schema
# curl http://localhost:8983/solr/films/schema \\
#-X POST -H 'Content-type:application/json' --data-binary '{
#    "add-field" : {
#        "name":"name",
#        "type":"text_general",
#        "multiValued":false,
#        "stored":true
#    },
#    "add-field" : {
#        "name":"initial_release_date",
#        "type":"tdate",
#        "stored":true
#    }
#}'


bin/pulsar-admin topics list public/default

bin/pulsar-admin topics subscriptions persistent://public/default/energy
  
bin/pulsar-admin topics unsubscribe --subscription energy-checker persistent://public/default/energy
bin/pulsar-admin topics unsubscribe --subscription nifi-pulsar-energy persistent://public/default/energy
  
bin/pulsar-admin topics unload persistent://public/default/energy

bin/pulsar-admin topics delete persistent://public/default/energy
bin/pulsar-admin topics delete persistent://public/default/energy-partition-0

bin/pulsar-admin schemas delete energy

bin/pulsar-admin schemas upload energy -f energy-schema.json

bin/pulsar-admin schemas get energy

bin/pulsar-client consume energy -s "energy-checker"

bin/pulsar-admin sink stop --name solr-sink-energy --namespace default --tenant public
bin/pulsar-admin sinks delete --tenant public --namespace default --name solr-sink-energy
bin/pulsar-admin sinks create --tenant public --namespace default --name solr-sink-energy --sink-type solr --sink-config-file conf/solr-sink-energy.yml --inputs energy
bin/pulsar-admin sinks get --tenant public --namespace default --name solr-sink-energy
bin/pulsar-admin sinks status --tenant public --namespace default --name solr-sink-energy

curl "http://localhost:8983/solr/energy/select?q=*"

docker exec 03ecc2709715 solr config -c energy -p 8983 -action set-user-property -property update.autoCreateFields -value false


java -jar target/IoTProducer-1.0-jar-with-dependencies.jar --serviceUrl pulsar://localhost:6650 --topic 'iotjetsonjson' --message

bin/pulsar-admin sink stop --name solr-sink-jetson --namespace default --tenant public
bin/pulsar-admin sinks delete --tenant public --namespace default --name solr-sink-jetson
bin/pulsar-admin sinks create --archive ./connectors/pulsar-io-solr-2.8.0.nar --tenant public --namespace default --name solr-sink-jetson --sink-config-file conf/solr-sink-jetson.yml --inputs iotjetsonjson --parallelism 1


bin/pulsar-admin sinks get --tenant public --namespace default --name solr-sink-jetson
bin/pulsar-admin sinks status --tenant public --namespace default --name solr-sink-jetson

bin/pulsar-client consume energy -s "energy-checker"