KafkaTopicDetails

从一个或多个 Kafka 代理检索有关指定主题的信息。此函数将列出有关主题分区的详细信息，以及为 Kafka 群集中的每个分区提供服务的 Kafka 代理。

语法

KafkaTopicDetails(USING PARAMETERS brokers='hostname:port[,hostname2:port2...]'
                                  , topic=topic_name
                                 [, kafka_conf='option=value[;option2=value2...]']
                                 [, timeout=timeout_sec])

brokers

Kafka 群集中代理的主机名（或 IP 地址）。

port

运行代理的端口号。

topic

您需要获取其详细信息的 Kafka 主题。

kafka_conf

要直接传递给 rdkafka 库的 option=value 对的分号分隔列表。这是 Vertica 用于与 Kafka 进行通信的库。您可以使用此参数直接设置通过 Vertica 与 Kafka 的集成所无法提供的配置选项。有关详细信息，请参阅直接设置 Kafka 库选项。

timeout

等待 Kafka 群集做出响应的整数秒数。

示例

=> SELECT KafkaTopicDetails(USING PARAMETERS brokers='kafka1-01.example.com:9092',topic='iot_data') OVER();
 partition_id | lead_broker | replica_brokers | in_sync_replica_brokers
--------------+-------------+-----------------+-------------------------
            0 |           0 | 0               | 0
            1 |           1 | 1               | 1
            2 |           0 | 0               | 0
            3 |           1 | 1               | 1
            4 |           0 | 0               | 0
(5 rows)