git404hub

what is kafka-connect-salesforce-oss fr?

osodevops/kafka-connect-salesforce-oss — explained in plain English

Analysis updated 2026-05-18

1JavaAudience · ops devopsComplexity · 4/5LicenseSetup · hard

tl;dr

An open-source, Apache-2.0 set of Kafka connectors that stream Salesforce data changes in real time and can also write data back into Salesforce.

vibe map

mindmap
  root((kafka connect salesforce))
    What it does
      Streams Salesforce changes
      Writes data back to Salesforce
      Confluent migration path
    Tech stack
      Java
      Apache Kafka
      Kafka Connect
      Maven
    Use cases
      Real time CDC streaming
      Historical data backfill
      Vendor lock-in avoidance
    Audience
      DevOps engineers
      Data platform teams

Code map

Detail Auto

An interactive map of this repo's files and how they connect — its source is parsed live in your browser. Click Visualize to build it.

filefunction / class

what do people make with this?

VIBE 1

Stream Salesforce record changes into Kafka in real time as they happen.

VIBE 2

Backfill historical Salesforce data and switch smoothly into live streaming.

VIBE 3

Write Kafka data back into Salesforce as record updates or platform events.

VIBE 4

Migrate an existing Confluent Salesforce connector setup with a verified, no-data-loss process.

what's the stack?

JavaApache KafkaKafka ConnectMaven

how it stacks up fr

osodevops/kafka-connect-salesforce-ossakarshsatija/beastalexeygrigorev/codeforces-solutions-java
Stars111
LanguageJavaJavaJava
Last pushed2021-02-172020-10-03
MaintenanceDormantDormant
Setup difficultyhardhardeasy
Complexity4/54/51/5
Audienceops devopsdatadeveloper

Figures from each repo's GitHub metadata at analysis time.

how do i run it?

Difficulty · hard time til it works · 1h+

Requires a running Kafka Connect worker plus Salesforce API credentials for production use, though local testing needs no real Salesforce org.

Apache 2.0 license: free to use, modify, and distribute, including commercially, with patent protection and attribution required.

in plain english

This project connects Salesforce and Apache Kafka, a system many companies use to move large streams of data between different parts of their software in real time. It is built as a free, open source alternative to a similar paid connector sold by Confluent, aiming to offer the same core capabilities without a commercial license. In practice, it offers four separate connector pieces. One watches a Salesforce account for changes, such as a new lead or an updated contact, and streams those changes into Kafka as they happen, using Salesforce's modern Pub or Sub API rather than an older method. It can also pull in a full historical snapshot of existing records first, then switch smoothly into live streaming without missing or duplicating anything. Two other connectors write data back into Salesforce from Kafka, either updating standard records or publishing what Salesforce calls platform events, which can trigger automated workflows inside Salesforce itself. A fourth connector supports an older Salesforce streaming method for accounts that do not have access to the newer API. The project pays attention to real world operational concerns: it tracks Salesforce's daily API usage limits and slows itself down before hitting them, it can recover automatically if it temporarily loses its place in the stream of changes, and it can run on any standard Kafka setup, including managed cloud services. It also includes a documented, tested process for migrating an existing Confluent based setup over to this project, including a way to verify afterward that no data was lost in the switch. Developers can test the whole system locally without needing an actual Salesforce account, since the project ships a fake version of Salesforce's APIs for testing. It requires Java 17 or newer and Maven to build from source, and is released under the Apache 2.0 license, making it suitable for companies wanting to avoid vendor lock-in on their Salesforce data pipeline.

prompts (copy fr)

prompt 1
Explain the difference between the source connector and the sink connectors in this project.
prompt 2
Walk me through setting up the example Docker Compose environment to test this connector.
prompt 3
How does this project avoid exceeding Salesforce's daily API usage limits?
prompt 4
Show me how to migrate an existing Confluent Salesforce connector config to this project.

Frequently asked questions

what is kafka-connect-salesforce-oss fr?

An open-source, Apache-2.0 set of Kafka connectors that stream Salesforce data changes in real time and can also write data back into Salesforce.

What language is kafka-connect-salesforce-oss written in?

Mainly Java. The stack also includes Java, Apache Kafka, Kafka Connect.

What license does kafka-connect-salesforce-oss use?

Apache 2.0 license: free to use, modify, and distribute, including commercially, with patent protection and attribution required.

How hard is kafka-connect-salesforce-oss to set up?

Setup difficulty is rated hard, with roughly 1h+ to a first successful run.

Who is kafka-connect-salesforce-oss for?

Mainly ops devops.

peek the repo → explain another one

This repo across BitVibe Labs

double-check against the repo, no cap.