Enterprise-grade export to Apache Kafka with support for partitions, replication, and high-throughput streaming. Ideal for building streaming data pipelines and real-time analytics.
open_in_new
Official Documentation
kafka.apache.org
Configuration Parameters
| Parameter | Required | Type | Default | Description |
|---|---|---|---|---|
| BootstrapServers | No | string | localhost:9092 | Comma-separated list of Kafka broker addresses. |
| Topic | No | string | proxus_device_data | Target Kafka topic for data export. |
| ClientId | No | string | (empty) | Client identifier for metric reporting. |
| SecurityProtocol | No | string | Plaintext | Security protocol: Plaintext, Ssl, SaslSsl, SaslPlaintext. |
| SaslMechanism | No | string | Plain | SASL mechanism: Plain, ScramSha256, ScramSha512, etc. |
| SaslUsername | No | string | (empty) | SASL authentication username. |
| SaslPassword | No | string | (empty) | SASL authentication password. |
Internal Behavior
Delivery Guarantees
This connector configures the Kafka producer for safe delivery:
- EnableIdempotence: Enabled to reduce duplicate writes on retries
- Retries: 3 retries with 1s backoff
- Request Timeout: 30s
Performance Features
- Async Publishing: Each payload is published asynchronously.
- Message Headers: Adds
DeviceName,DeviceId, andTimestampheaders. - Message Key: Uses the payload key as Kafka message key.