Table | cm_kafka_servers |
|---|---|
Description | Kafka Servers |
Column | Format | Description | Definition | Comments |
|---|---|---|---|---|
id | integer, primary key | Row identifier | autoincrement | |
server_id | integer, foreign key | Server ID | cm_servers:id | |
brokers | text | Broker(s) to connect to | A comma separated list in host:port notation; converted from varchar(256) in Registry v4.2.0 | |
username | varchar(128) | Username to bind as | ||
password | varchar(400) | Password to bind with | ||
| security_protocol | varchar(24) | Kafka security protocol | ||
| sasl_mechanism | varchar(24) | Kafka SASL mechanism | ||
| groupid | varchar(80) | Kafka Client Group ID string | Added in Registry v4.1.0 | |
| topic | varchar(80) | Kafka Topic to consume | Added in Registry v4.1.0 | |
| batch_size | integer | Number of records to consume per batchConsume operation | Added in Registry v4.1.0 | |
| partition | integer | Kafka Partition ID to consume from | Added in Registry v4.1.0 | |
| timeout | integer | Timeout (in seconds) when trying to consume | Added in Registry v4.1.0 |