Selfuel Docs
  • Welcome to Selfuel Platform
    • Features
    • Capabilities
    • Target Audience
    • $150 Free Trial
  • Registration and Login
  • Platform UI
  • Stream Processing with Cortex
    • Cortex Quickstart Guide
    • Cortex Elements
      • Streams
      • Attributes
      • Mappings
        • 🚧Source Mapping Types
        • 🚧Sink Mapping Types
      • Node and Application Healthchecks
      • Nodes
        • Node Preview
        • Node Connectivites
        • Node Units
      • Expression Builder
        • 🚧Built-in Functions
      • Windows
        • Cron Window
        • Delay Window
        • Unique Event Window
        • First Event Window
        • Sliding Event Count Window
        • Tumbling Event Count Window
        • Session Window
        • Tumbling Event Sort Window
        • Sliding Time Window
        • Tumbling Time Window
        • Sliding Time and Event Count Window
      • Store and Cache
        • RDBMS
        • MongoDB
        • Redis
        • Elasticsearch
    • Applications
      • Applications Page
      • Creating Applications using Canvas
      • Connector Nodes Cluster
        • Source Nodes
          • CDC Source
          • Email Source
          • HTTP Source
          • HTTP Call Response Source
          • HTTP Service Source
          • Kafka Source
          • RabbitMQ Source
          • gRPC Source
          • JMS Source
          • Kafka Multi DC Source
          • JMS Source
          • AWS S3 Source
          • Google Pub-sub Source
          • AWS SQS Source
          • MQTT Source
          • Google Cloud Storage Source
          • HTTP SSE Source
          • WebSubHub Source
        • Sink Nodes
          • Email Sink
          • HTTP Sink
          • HTTP Service Response Sink
          • HTTP Call Sink
          • Kafka Sink
          • RabbitMQ Sink
          • gRPC Sink
          • JMS Sink
          • Kafka Multi DC Sink
          • AWS S3 Sink
          • Google Pub-sub Sink
          • AWS SQS Sink
          • MQTT Sink
          • Google Cloud Storage Sink
          • HTTP SSE Sink
          • WebSubHub Sink
      • Processing Nodes Cluster
        • Query
        • Join
        • Pattern
        • Sequence
        • Processor
        • 🚧On-demand Query
      • Buffer Nodes Cluster
        • Stream
        • Table
        • Window
        • Aggregation
        • Trigger
    • Run Applications
      • Run Applications Using Runners
      • Update Running Applications
      • Application Versioning
  • Data Integration with Nexus
    • Nexus Quickstart Guide
    • Nexus Elements
      • Concept
        • Config
        • Schema Feature
        • Speed Control
      • Connectors
        • Source
          • Source Connector Features
          • Source Common Options
          • AmazonDynamoDB
          • AmazonSqs
          • Cassandra
          • Clickhouse
          • CosFile
          • DB2
          • Doris
          • Easysearch
          • Elasticsearch
          • FakeSource
          • FtpFile
          • Github
          • Gitlab
          • GoogleSheets
          • Greenplum
          • Hbase
          • HdfsFile
          • Hive
          • HiveJdbc
          • Http
          • Apache Iceberg
          • InfluxDB
          • IoTDB
          • JDBC
          • Jira
          • Kingbase
          • Klaviyo
          • Kudu
          • Lemlist
          • Maxcompute
          • Milvus
          • MongoDB CDC
          • MongoDB
          • My Hours
          • MySQL CDC
          • MySQL
          • Neo4j
          • Notion
          • ObsFile
          • OceanBase
          • OneSignal
          • OpenMldb
          • Oracle CDC
          • Oracle
          • OssFile
          • OssJindoFile
          • Paimon
          • Persistiq
          • Phoenix
          • PostgreSQL CDC
          • PostgreSQL
          • Apache Pulsar
          • Rabbitmq
          • Redis
          • Redshift
          • RocketMQ
          • S3File
          • SftpFile
          • Sls
          • Snowflake
          • Socket
          • SQL Server CDC
          • SQL Server
          • StarRocks
          • TDengine
          • Vertica
          • Web3j
          • Kafka
        • Sink
          • Sink Connector Features
          • Sink Common Options
          • Activemq
          • AmazonDynamoDB
          • AmazonSqs
          • Assert
          • Cassandra
          • Clickhouse
          • ClickhouseFile
          • CosFile
          • DB2
          • DataHub
          • DingTalk
          • Doris
          • Druid
          • INFINI Easysearch
          • Elasticsearch
          • Email
          • Enterprise WeChat
          • Feishu
          • FtpFile
          • GoogleFirestore
          • Greenplum
          • Hbase
          • HdfsFile
          • Hive
          • Http
          • Hudi
          • Apache Iceberg
          • InfluxDB
          • IoTDB
          • JDBC
          • Kafka
          • Kingbase
          • Kudu
          • Maxcompute
          • Milvus
          • MongoDB
          • MySQL
          • Neo4j
          • ObsFile
          • OceanBase
          • Oracle
          • OssFile
          • OssJindoFile
          • Paimon
          • Phoenix
          • PostgreSql
          • Pulsar
          • Rabbitmq
          • Redis
          • Redshift
          • RocketMQ
          • S3Redshift
          • S3File
          • SelectDB Cloud
          • Sentry
          • SftpFile
          • Slack
          • Snowflake
          • Socket
          • SQL Server
          • StarRocks
          • TDengine
          • Tablestore
          • Vertica
        • Formats
          • Avro format
          • Canal Format
          • CDC Compatible Debezium-json
          • Debezium Format
          • Kafka source compatible kafka-connect-json
          • MaxWell Format
          • Ogg Format
        • Error Quick Reference Manual
      • Transform
        • Transform Common Options
        • Copy
        • FieldMapper
        • FilterRowKind
        • Filter
        • JsonPath
        • LLM
        • Replace
        • Split
        • SQL Functions
        • SQL
    • Integrations
      • Integrations Page
      • Creating Integrations Using Json
    • Run Integrations
      • Run Integrations Using Runners
      • Integration Versioning
  • Batch Processing/Storage with Maxim
    • Maxim Quickstart Guide
    • Maxim Elements
    • Queries
    • Run Queries
  • Orchestration with Routines
    • Routines Quickstart Guide
    • Routines Elements
    • Routines
    • Run Routines
  • Runners
    • Runners Page
    • Create a Runner to Run Applications
  • Security
    • Vaults
      • Vaults Page
      • Create Vaults
        • Runner-level Vaults
        • Application-level Vaults
      • Edit and Delete Vaults
      • 🚧Utilizing Vaults in Applications and Runners
    • Certificates
      • Certificates Page
      • 🚧Utilizing Certificates in Applications
      • 🟨Setting Up Security Settings
  • Monitoring Performance
    • Dashboard
    • Application Details
    • Runner Details
  • Logging
    • Log Types
  • Cost Management
    • SaaS
      • Pay-as-you-go
        • Hard Budget Cap
        • Soft Budget Cap
      • Subscriptions
    • On-prem
  • Organization Settings
    • General
    • Access Controls
      • User Roles and Privileges
    • Current Costs
    • Billing Addresses
    • Payment Accounts
    • Subscriptions
    • Pricing
    • Invoicing
  • User Settings
  • Troubleshooting
  • FAQs
Powered by GitBook
On this page
  • Step 4 - Connection and Secuirty Settings
  • Event Publishing URL
  • HTTP Method
  • Enable SSL Verification
  • Certificates
  • ...X
  • Step 5 - Authentication and Logging
  • Basic Authentication Username
  • Basic Authentication Password
  • Enable OAuth
  • OAuth Username
  • OAuth Password
  • OAuth Consumer Key
  • OAuth Consumer Secret
  • OAuth Token URL
  • OAuth Refresh Token
  • ...X
  • Step 6 - Worker and Connection Management
  • Client Bootstrap Settings
  • Maximum Active Connections
  • Minimum Idle Connections
  • Maximum Idle Connections
  • Minimum Evictable Idle Time
  • Time Between Eviction Runs
  • ...X
  • Step 7 - Advanced SSL/TLS Configurations
  • HTTP Request Headers
  • Enable Response Downloading
  • Download Path
  • Block Request Thread Until Response Received
  • SSL/TLS Configurations
  • Step 8 - Preview
  1. Stream Processing with Cortex
  2. Applications
  3. Connector Nodes Cluster
  4. Sink Nodes

HTTP Sink

PreviousEmail SinkNextHTTP Service Response Sink

Last updated 1 year ago

Step 4 - Connection and Secuirty Settings

Event Publishing URL

Specify the URL where the outgoing events will be sent. For instance: or .

Default Value
Possible Data Type

STRING

HTTP Method

Select the HTTP method to use when calling the endpoint.

Write methods other than POST

Default Value
Possible Data Type

POST

STRING

Enable SSL Verification

Choose to disable SSL certificate verification.

Either explain the double negative or take care of it at the BE

Default Value
Possible Data Type

OFF

Certificates

You can upload certificates that are already uploaded in Certificates or upload a new one from below.

...X

Step 5 - Authentication and Logging

Basic Authentication Username

Enter the username for basic authentication.

Default Value
Possible Data Type

STRING

Basic Authentication Password

Enter the password for basic authentication.

Default Value
Possible Data Type

STRING

Enable OAuth

Turn toggle ON to enable OAuth 2.0 Authorization.

Default Value
Possible Data Type

OFF

OAuth Username

Provide the username for OAuth 2.0 authentication.

Default Value
Possible Data Type

STRING

OAuth Password

Provide the password for OAuth 2.0 authentication.

Default Value
Possible Data Type

STRING

OAuth Consumer Key

Enter the consumer key for OAuth 2.0 secured endpoints.

Default Value
Possible Data Type

STRING

OAuth Consumer Secret

Enter the consumer secret for OAuth 2.0 secured endpoints.

Default Value
Possible Data Type

STRING

OAuth Token URL

Provide the URL for generating new access tokens for OAuth 2.0 authentication.

Default Value
Possible Data Type

STRING

OAuth Refresh Token

Enter the refresh token for generating new OAuth 2.0 access tokens.

Default Value
Possible Data Type

STRING

...X

Step 6 - Worker and Connection Management

Client Bootstrap Settings

Enter client bootstrap configurations in the key-value format. Some supported configurations can be exemplified as

  • Client Connect Timeout in Milliseconds: 'client.bootstrap.connect.timeout' as key and '10000' as value.

  • Client Socket Timeout in Seconds: 'client.bootstrap.socket.timeout' as key and '15' as value.

  • Client Socket Reuse: 'client.bootstrap.socket.reuse' as key and 'true' as value.

  • Enable TCP No Delay: 'client.bootstrap.nodelay' as key and 'true' value.

  • Enable Client Keep Alive: 'client.bootstrap.keepalive' as key and 'true' value.

  • Send Buffer Size: 'client.bootstrap.sendbuffersize' as key and '1048576' as value.

  • Receive buffer size: 'client.bootstrap.recievebuffersize' as key and '1048576' as value.

Default Value
Possible Data Type

STRING

Maximum Active Connections

Set the maximum number of active connections per client pool.

The default value of '-1' denotes unlimited number of Maximum Active Connections.

Default Value
Possible Data Type

-1

INTEGER

Minimum Idle Connections

Set the minimum number of idle connections in the client pool.

Default Value
Possible Data Type

0

INTEGER

Maximum Idle Connections

Set the maximum number of idle connections in the client pool.

Default Value
Possible Data Type

100

INTEGER

Minimum Evictable Idle Time

Specify the minimum time in milliseconds that a connection can be idle before it is eligible for eviction from the client pool.

Default Value
Possible Data Type

300000

STRING

Time Between Eviction Runs

Set the interval in milliseconds between two eviction operations on the client pool.

Default Value
Possible Data Type

30000

STRING

...X

Step 7 - Advanced SSL/TLS Configurations

HTTP Request Headers

Enter Content Type and Content Length HTTP Request headers in the key-value format.

Unless expressed here; the system will deduce the Content-Type from the Mapping (Step 3) and calculate the Content-Length automatically.

Default Value
Possible Data Type

STRING

Enable Response Downloading

Default Value
Possible Data Type

STRING

Download Path

Default Value
Possible Data Type

STRING

Block Request Thread Until Response Received

Default Value
Possible Data Type

STRING

SSL/TLS Configurations

Specifies configurations for SSL/TLS in the key-value pairs. Vaules can be separated by commas (',') Some supported parameters can be exemplified as

  • SSL/TLS protocols: ‘sslEnabledProtocols' as key and 'TLSv1.1,TLSv1.2’ as values.

  • List of ciphers: ‘ciphers’ as key and 'TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256' as value.

  • Enable Session Creation: 'client.enable.session.creation' as key and 'true’ as value.

  • Supported server names: ‘server.supported.server.names’ as key and 'server_name’ as value.

  • Add HTTP SNIMatcher: ‘server.supported.snimatcher' as key and 'SNIMatcher’ as value

Default Value
Possible Data Type

STRING

Step 8 - Preview

In Preview Step, you're provided with a concise summary of all the changes you've made to the HTTP Sink Node. This step is pivotal for reviewing and ensuring that your configurations are as intended before completing node setup.

  • Viewing Configurations: Preview Step presents a consolidated view of your node setup.

  • Saving and Exiting: Use the Complete button to save your changes and exit the node and return back to Canvas.

  • Revisions: Use the Back button to return to any Step of modify node setup.

The Preview Step offers a user-friendly summary to manage and finalize node settings in Cortex.

http://localhost:8080/endpoint
https://localhost:8080/endpoint