Source Utility Options
Use the source utility to create, update, or delete a source.
Option | Description |
---|---|
--source source_name |
The source to add, remove, or edit from a scheduler configuration. In most cases, the source is the name of your Kafka cluster. |
--new-source source_name |
Updates the name of an existing source to the name specified by this parameter. Requires: |
--partitions count |
Used to create all partitions from 0 to n–1. Default Value: 1 Requires: You must keep this consistent with the number of partitions in the source. Renamed from |
--cluster cluster_name |
Identifies the cluster that you want to edit. |
--new-cluster cluster_name |
Updates the name of an existing cluster to the name specified by this parameter. All sources referencing the old cluster source now target this cluster. Requires: |
enabled TRUE|FALSE | When TRUE, the source is available for use. |
Examples
The following examples show how you can create or update SourceFeed and assign it to a cluster.
Create the source SourceFeed and assign it to the cluster, StreamCluster1:
/opt/vertica/packages/kafka/bin/vkconfig source --create --source SourceFeed --cluster StreamCluster1 --partitions 3
Update the existing source SourceFeed to use the existing cluster, StreamCluster2:
/opt/vertica/packages/kafka/bin/vkconfig source --update --source SourceFeed --new-cluster StreamCluster2