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. 

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
    echo "SALESFORCE_USERNAME=<YOUR SALESFORCE USERNAME>" >> .env
    echo "SALESFORCE_PASSWORD=<YOUR SALESFORCE PASSWORD>" >> .env
    set -o allexport
    source .env
    set +o allexport
   

3. Setup the Kafka certs:

    bin/setup_certs.sh
   

4. Run the app:

    ./activator ~run