Consume messages from Apache Kafka topics to detect active assets based on security event telemetry.
- Apache Kafka 2.0 or later
- Network access from SilentPulse to Kafka brokers
- SASL credentials (if authentication is enabled)
| Field | Type | Required | Description |
|---|
brokers | text | yes | Comma-separated list of Kafka brokers |
username | text | no | SASL username |
password | password | no | SASL password |
use_tls | boolean | no | Enable TLS |
| Field | Type | Required | Default | Description |
|---|
topic | text | yes | | Kafka topic to consume from |
consumer_group | text | no | silentpulse | Consumer group ID |
hostname_field | text | yes | hostname | JSON field containing the asset hostname |
The connector joins a Kafka consumer group and reads messages from the configured topic. Each message is parsed as JSON, and the hostname is extracted from the configured field.
The connector supports horizontal scaling based on Kafka partition count. Set max_replicas to match your partition count for optimal throughput. Scaling key: partitions.
| Resource | Request |
|---|
| CPU | 100m |
| Memory | 128Mi |
| Min replicas | 1 |
| Max replicas | 8 |
- Consumer group must be unique per SilentPulse instance
- Max message size: 1MB
