Skip to content

Fix Salesforce: replace orphan processor wrapper with three input wrappers #592

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Feediver1 wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Fix Salesforce: replace orphan processor wrapper with three input wrappers #592

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion modules/ROOT/nav.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,9 @@
**** xref:develop:connect/components/inputs/redpanda_common.adoc[]
**** xref:develop:connect/components/inputs/redpanda_migrator.adoc[]
**** xref:develop:connect/components/inputs/resource.adoc[]
**** xref:develop:connect/components/inputs/salesforce.adoc[]
**** xref:develop:connect/components/inputs/salesforce_cdc.adoc[]
**** xref:develop:connect/components/inputs/salesforce_graphql.adoc[]
**** xref:develop:connect/components/inputs/schema_registry.adoc[]
**** xref:develop:connect/components/inputs/sequence.adoc[]
**** xref:develop:connect/components/inputs/sftp.adoc[]
Expand Down Expand Up @@ -239,7 +242,6 @@
**** xref:develop:connect/components/processors/redis_script.adoc[]
**** xref:develop:connect/components/processors/resource.adoc[]
**** xref:develop:connect/components/processors/retry.adoc[]
**** xref:develop:connect/components/processors/salesforce.adoc[]
**** xref:develop:connect/components/processors/schema_registry_decode.adoc[]
**** xref:develop:connect/components/processors/schema_registry_encode.adoc[]
**** xref:develop:connect/components/processors/select_parts.adoc[]
Expand Down
3 changes: 3 additions & 0 deletions modules/develop/pages/connect/components/inputs/salesforce.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
= salesforce
:page-aliases: components:inputs/salesforce.adoc, components:processors/salesforce.adoc
include::redpanda-connect:components:inputs/salesforce.adoc[tag=single-source]
3 changes: 3 additions & 0 deletions modules/develop/pages/connect/components/inputs/salesforce_cdc.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
= salesforce_cdc
:page-aliases: components:inputs/salesforce_cdc.adoc
include::redpanda-connect:components:inputs/salesforce_cdc.adoc[tag=single-source]
3 changes: 3 additions & 0 deletions modules/develop/pages/connect/components/inputs/salesforce_graphql.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
= salesforce_graphql
:page-aliases: components:inputs/salesforce_graphql.adoc
include::redpanda-connect:components:inputs/salesforce_graphql.adoc[tag=single-source]
3 changes: 0 additions & 3 deletions modules/develop/pages/connect/components/processors/salesforce.adoc
View file
Open in desktop

This file was deleted.

5 changes: 4 additions & 1 deletion modules/get-started/pages/whats-new-cloud.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -52,12 +52,15 @@ The Redpanda Terraform provider (v1.6.0+) now supports https://developer.hashico
=== Redpanda Connect updates

* The Redpanda Connect pipeline creation and editing workflow has been simplified. The new UI replaces the previous multi-page wizard with a visual pipeline diagram, an IDE-like configuration editor, slash commands for inserting variables, and inline links to component documentation. See the xref:develop:connect/connect-quickstart.adoc[Redpanda Connect quickstart] to try it out.
* Inputs:
** xref:develop:connect/components/inputs/salesforce.adoc[salesforce]: Run a SOQL query against the Salesforce REST API, paginate through all result pages, and emit one message per record.
** xref:develop:connect/components/inputs/salesforce_cdc.adoc[salesforce_cdc]: Subscribe to one or more Salesforce Pub/Sub topics in parallel for Change Data Capture and Platform Events, with optional REST snapshot before streaming.
** xref:develop:connect/components/inputs/salesforce_graphql.adoc[salesforce_graphql]: Execute a GraphQL query against the Salesforce UIAPI and emit one message per record, with cross-object queries in a single request.
* Outputs:
** xref:develop:connect/components/outputs/arc.adoc[arc]: Send data to an Arc columnar analytical database using its high-performance MessagePack ingestion endpoint.
** xref:develop:connect/components/outputs/salesforce_sink.adoc[salesforce_sink]: Write messages to Salesforce, routing each Kafka topic to its own sObject configuration. Supports both realtime (sObject Collections REST API) and bulk modes (Bulk API 2.0).
* Processors:
** xref:develop:connect/components/processors/string_split.adoc[string_split]: Splits strings into multiple parts using a delimiter, creating new messages or fields for each part.
** xref:develop:connect/components/processors/salesforce.adoc[salesforce]: Fetch data from Salesforce based on input messages. Supports sObject REST snapshots, SOQL queries via REST or GraphQL, Change Data Capture (CDC) streaming, and Platform Events via the Pub/Sub gRPC API.

== March 2026

Expand Down