# Copyright 2026 Aiven Oy
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# SPDX-License-Identifier: Apache-2.0

# ---------------------------------------------------------------------------
# This is a an example of a basic sink connector configuration.

# For additional information:
# - https://kafka.apache.org/42/kafka-connect/
# - https://aiven-open.github.io/salesforce-connector-for-apache-kafka/sink/configuration.html

name=AccountSink
connector.class=io.aiven.kafka.connect.salesforce.sink.SalesforceSinkConnector
tasks.max=3

# Comma separated list of accounts to use (alternatively use topic.regex to specify a set)
topics=account

# How the messages in the Kafka topic are converted into Kafka Connect records
value.converter=org.apache.kafka.connect.json.JsonConverter

# How often to flush records to the Salesforce sink; a larger interval means fewer API calls but larger batches
offset.flush.interval.ms=60000
# The maximum time to wait for each flush to complete (default is 5000 ms); increase this for large batches or high Salesforce latency
offset.flush.timeout.ms=5000

# The maximum number of times to retry an insert or authentication request against the Bulk API before failing
max.retries=3

# The version of the Salesforce API to use for all queries
salesforce.api.version=v65.0

# The Salesforce client id (also known as consumer key) and secret.
# https://developer.salesforce.com/docs/atlas.en-us.sfdx_dev.meta/sfdx_dev/sfdx_dev_auth_eca.htm#sfdx_dev_auth_eca
salesforce.client.id=CONSUMER_KEY
salesforce.client.secret=CONSUMER_SECRET

# The Salesforce OAuth URI may be unique for your Salesforce deployment.

# Sandbox: salesforce.oauth.uri=https://test.salesforce.com/services/oauth2/token
# Org-specific domain: salesforce.oauth.uri=https://<your-domain>.my.salesforce.com/services/oauth2/token
# Developer edition: salesforce.oauth.uri=https://orgfarm-1234abc123-dev-ed.develop.my.salesforce.com/services/oauth2/token
# Production:
salesforce.oauth.uri=https://login.salesforce.com/services/oauth2/token

salesforce.uri=https://orgfarm-1234abc123-dev-ed.develop.my.salesforce.com