by jamesward

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. Deploy on Heroku

  4. Add the Heroku Kafka Addon to the app

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

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

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

     heroku kafka:topics:create ContactUpdates --partitions 32 -a YOUR_APP
  8. Watch the Kafka log

     heroku kafka:topics:tail ContactUpdates -a YOUR_APP
  9. 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. Run the app:

     ./activator ~run