群集工具选项

vkconfig 脚本的群集工具可用于定义调度程序连接到的流式传输主机。

语法

vkconfig cluster {--create | --read | --update | --delete} [--cluster cluster_name] [other_options...]

--create

创建新的负载规范，不能与 ‑‑delete、‑‑read 或 ‑‑update 一起使用。

--read

输出调度程序中定义的所有群集的设置。此输出采用 JSON 格式。不能与 --create、--delete 或 --update 配合使用。

您可以通过在 --cluster 选项中提供一个或多个群集名称将输出限制为特定群集。此外，还可以使用 --hosts 选项将输出限制为包含一个或多个特定主机的群集。使用逗号分隔多个值。

您可以在这些选项中使用 LIKE 通配符。有关使用通配符的详细信息，请参阅 LIKE 谓词。

--update

更新现有的 Set Snippet Variable Value in Topic。不能与 --create、--delete 或 --read 配合使用。

--delete

删除 Set Snippet Variable Value in Topic。不能与 --create、--read 或 --update 配合使用。

--dump

当您将此选项与 --read 选项一起使用时，vkconfig 会输出用来检索数据的 Vertica 查询，而不是输出数据本身。如果您想从 Vertica 中访问数据而无需通过 vkconfig，则此选项很有用。如果不与 --read 一起使用，此选项无效。

--clustercluster_name

要对其执行操作的群集的唯一名称，不区分大小写。--create、--update 和 --delete 需要使用此选项。

--hostsb1:port[,b2:port...]

标识要从 Kafka 群集添加、编辑或移除的代理主机。要标识多个主机，请使用逗号分隔符。

\--kafka_conf 'kafka_configuration_setting'

采用 JSON 格式直接传递给 rdkafka 库的选项/值对的对象。这是 Vertica 用于与 Kafka 进行通信的库。您可以使用此参数直接设置通过 Vertica 与 Kafka 的集成所无法提供的配置选项。有关详细信息，请参阅直接设置 Kafka 库选项。

--new-clustercluster_name

更新后的群集名称。需要使用 --update 共享的实用程序选项。

--validation-typERROR|WARN|SKIP}

指定在创建或更新后的群集上执行的验证级别：

• ERROR - 如果 vkconfig 无法验证该群集是否存在，请取消配置或创建。这是默认设置。

• WARN - 验证失败时继续执行任务，但会显示警告。

• SKIP - 不执行验证。

已重命名自 --skip-validation。

请参阅常用 vkconfig 脚本选项以了解所有 vkconfig 工具中提供的选项。

示例

以下示例显示如何创建群集 StreamCluster1 并分配两个主机：

$ /opt/vertica/packages/kafka/bin/vkconfig cluster --create --cluster StreamCluster1 \
                                           --hosts 10.10.10.10:9092,10.10.10.11:9092
                                           --conf myscheduler.config

以下示例显示如何列出与 weblogs.conf 文件中定义的调度程序关联的所有群集：

$ vkconfig cluster --read --conf weblog.conf
{"cluster":"kafka_weblog",
"hosts":"kafka01.example.com:9092,kafka02.example.com:9092"}