- [https://learn.microsoft.com/en-us/sql/sql-server]
- [https://learn.microsoft.com/en-us/sql/connect/jdbc]
- [https://learn.microsoft.com/en-us/sql/database-engine/configure-windows/authentication-access]
Core Functionality
- Relational Data Ingestion: Reads data from SQL Server tables into Condense streams.
- Secure Connectivity: Connects using authenticated SQL Server credentials over TCP.
- Structured Mapping: Converts each database row into a JSON event.
- Kafka-Native Output: Publishes records into Condense Kafka topics for downstream use.
- Scalable Reads: Supports ingestion from large tables for analytics and reporting pipelines.
- Database Connection:
The connector establishes a connection to the SQL Server instance using the provided hostname, port, and credentials. - Table Access:
The specified database and table are queried based on the connector configuration. - Data Extraction:
Rows from the table are read and serialized into structured JSON payloads. - Event Publishing:
Each extracted record is published to a configured Condense Output Topic. - Downstream Processing:
The published data can be transformed, filtered, or routed using Condense pipelines and connectors.
Field-by-Field Explanation
1. Title
A user-defined name to identify the SQL Server Input Connector in Condense.
Example:
SQLServer_Input_Orders
2. SQL Server Hostname Hostname or IP address of the SQL Server instance. Example:
sqlserver.company.internal
3. SQL Server Port Port on which SQL Server is listening. Default:
1433
4. Database Username Username used to authenticate with SQL Server. Example:
db_reader_user
5. Database Password Password associated with the configured database user.
6. Database Name Name of the SQL Server database from which data will be read. Example:
sales_db
7. Table Name Name of the table to ingest. Example:
orders
8. Output Topic Kafka-native Condense topic where SQL Server records will be published. Example:
sqlserver_orders_stream
Sample Configuration Example
- Verify hostname, port, and network reachability.
- Ensure SQL Server allows remote connections.
- Confirm username and password are correct.
- Ensure the user has read access to the target database and table.
- Verify the table contains records.
- Ensure the selected Output Topic exists and is active in Condense.
- Confirm the database user has
SELECTprivileges on the specified table.
- Ingesting large tables may produce high event volumes.
- Ensure downstream topics are appropriately configured.
- Changes to the table schema are reflected automatically in emitted JSON payloads.
- SQL Server data types are mapped to equivalent JSON representations.
- Use dedicated read-only database users for Condense ingestion.
- Assign clear and descriptive connector titles.
- Use separate topics per table or data domain for better pipeline organization.
- Monitor connector status and topic throughput using Condense monitoring tools.