Apache Kafka is an open-source distributed event streaming platform for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications.

Changelog

5 versions
v1.2.3 Latest
  • Reduced icon size for better performance.
v1.2.2
  • Added support for SSL option `passphrase`.
  • Added consumer run option `partitionsConsumedConcurrently` configurable in the Backoffice. Default is 3.
  • Added support for Snappy compression via kafkajs-snappy.
v1.2.1
  • NewMessage: added support for consumer options (https://kafka.js.org/docs/consuming#a-name-options-a-options).
v1.1.0
  • Added support for more SSL options.
v1.0.1
  • Initial version.

Authentication

TypeDetails
API Key
Client ID (text)
A logical identifier of an application. Choose a meaningful name to logically group your clients. Example: booking-events-processor.
Brokers (text)
A comma separated list of broker addresses. Example: glider.srvs.cloudkafka.com:9094.
SSL (text)
Enable/Disable SSL. Enter the string
SSL Reject Unauthorized (select)
Reject unauthorized SSL certificates. `true` or `false`.
TLS CA File (textarea)
Paste text content of ca.pem file.
TLS Key (textarea)
Paste text content of service.key file.
TLS Key passphrase/password (text)
TLS passphrase/password (optional).
TLS Cert (textarea)
Paste text content of service.cert file.
SASL Mechanism (text)
SASL mechanism type. Supported values: SCRAM-SHA-256, SCRAM-SHA-512, PLAIN. If provided, the saslUsername and saslPassword fields are required and all the SSL certificates are ignored.
SASL Username (text)
SASL username.
SASL Password (password)
SASL password

Triggers

1
New Message icon

New Message

Consume messages in a topic.

Actions

1
Send Message icon

Send Message

Publish a message.