snctl
): The unified command-line interface for deploying and managing StreamNative Cloud infrastructure and interacting directly with your Pulsar clusters and Kafka-protocol endpoints.pulsarctl
): For managing cluster-specific resources, such as tenants, namespaces, topics, functions, connectors, and more.my-aws-connection
.Connected
in the Cloud Connections tab.
my-aws-connection
. Then click Environment setup.
us-west-2
.poc
.10.0.0.0/16
. If you need to specify a different CIDR, you can enter it here.my-pulsar-instance
.my-aws-connection
.Classic Engine
.my-byoc-cluster
.aws-usw2-poc-<random-suffix>
.LTS
.produce
and consume
permissions for this namespace.
produce
and consume
permissions for this namespace. You can now continue on to building a Python app, connecting to the cluster, and producing and consuming messages.
pulsar-client
python client library.
producer.py
and consumer.py
. Copy and paste the sample code for the producer into producer.py
and the sample code for the consumer into consumer.py
. In both files, replace <JWT Token>
with the API key you copied from the Service Account page.
consumer.py
file, and run the following command:
producer.py
file, and run the following command: