Kafka integration with Vertica: ERROR: KafkaCheckBrokers() does not exist

jkiran2020

As part of kafka integration with Vertica testing, issue below command to
"Create a source cluster for Kafka running locally and associate it with kafka host".

dbadmin=> ! /opt/vertica/packages/kafka/bin/vkconfig cluster --dbhost xxxxx --dbport 5433 --username dbadmin --password xxx --config-schema stream_example --create --cluster kafka_cluster_1 --hosts xyz:9092

Received:
Exception in thread "main" com.vertica.solutions.kafka.exception.ConfigurationException: ERROR: [[Vertica]VJDBC ERROR: Function KafkaCheckBrokers() does not exist, or permission is denied for KafkaCheckBrokers()]

Could any one please help how to get around this.

Jim_Knicely

Are you running the command in VSQL? You should run it at the OS command line as the dbadmin user, not in VSQL.

Ben_Vandiver

Does your kafka scheduler version match the database version?