by herokumx

GitHub Readme.md

Hello Kafka Salesforce

This simple app uses the Salesforce Streaming API to listen for events in Salesforce and then sends them to Kafka.

Cloud Setup

  1. Signup for a Salesforce Developer Org

  2. In Salesforce, create a PushTopic using the Execute Anonymous Apex feature in the Developer Console:

     PushTopic pushTopic = new PushTopic();
     pushTopic.Name = 'ContactUpdates';
     pushTopic.Query = 'SELECT Id, Name FROM Contact';
     pushTopic.ApiVersion = 36.0;
     pushTopic.NotifyForOperationCreate = true;
     pushTopic.NotifyForOperationUpdate = true;
     pushTopic.NotifyForOperationUndelete = true;
     pushTopic.NotifyForOperationDelete = true;
     pushTopic.NotifyForFields = 'Referenced';
     insert pushTopic;
  3. Sign up for the Heroku Kafka preview

  4. Deploy on Heroku

  5. Add the Heroku Kafka Addon to the app

     heroku addons:add heroku-kafka - a YOUR_APP
  6. Install the Kafka plugin into the Heroku CLI

     heroku plugins:install heroku-kafka
  7. Wait for Kafka to be provisioned:

     heroku kafka:wait -a YOUR_APP
  8. Add a new Kafka topic:

     heroku kafka:create ContactUpdates -a YOUR_APP
  9. Watch the Kafka log

     heroku kafka:tail ContactUpdates -a YOUR_APP
  10. Make a change to a Contact in Salesforce and you should see the event in the Kafka log.

Local Setup

This uses the same Kafka system as above.

  1. Clone the source:

     git clone https://github.com/jamesward/hello-kafka-salesforce
  2. Setup a .env file with the necessary info:

     heroku config -s > .env
     set -o allexport
     source .env
     set +o allexport
  3. Setup the Kafka certs:

  4. Run the app:

     ./activator ~run