As pushing the application into IBM Cloud® does not require you to build the application locally, this guide is here to guide you through the process, should you wish to build the application locally.
We will not discuss establishing a connection from your laptop to Event Streams for IBM Cloud. This is described in the connection guide.
- Python 3.6 or later
- Open Keychain Access, export all certificates in System Roots to a single .pem file
Run the following commands on your local machine, after the prerequisites for your environment have been completed:
pip install -r requirements.txt
Once built, to run the sample, execute the following command:
python3 app.py <kafka_brokers_sasl> <kafka_admin_url> <api_key> <ca_location>
To find the values for <kafka_brokers_sasl>
, <kafka_admin_url>
and <api_key>
, access your Event Streams instance in IBM Cloud®, go to the Service Credentials
tab and select the Credentials
you want to use. If your user value is token
, specify that with the password seperated by a :
.
<ca_location>
is the path where the trusted SSL certificates are stored on your machine and is therefore system dependent.
For example:
- Ubuntu: /etc/ssl/certs
- RedHat: /etc/pki/tls/cert.pem
- macOS: The .pem file you created in the prerequisite section
Note: <kafka_brokers_sasl>
must be a single string enclosed in quotes. For example: "host1:port1,host2:port2"
. We recommend using all the Kafka hosts listed in the Credentials
you selected.
Alternatively, you can run only the producer or only the consumer by respectively appending the switches -producer
or -consumer
to the command above.
The sample will run indefinitely until interrupted. To stop the process, use Ctrl+C
.