kafkaCheckBrokers function issues

mdkarkeys

Hi,
We are on vertica 8.1.1. We need to stream data from Kafka directly into vertica.
I'm running the following vkconfig command to create cluster and its failing with the error kafkaCheckBrokers() function doesn't exist (or) I don't have permissions. When I check in public schema, I don't see this function. appreciate any help on this..

/opt/vertica/packages/kafka/bin/vkconfig cluster --create --config-schema weblog_sched1 --cluster kafka1 --hosts kafka01.example.com:2021,kafka02.example.com:2021,kafka03.example.com:2021:2021 --conf weblog.conf

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()]
at com.vertica.solutions.kafka.model.StreamCluster.validateConfiguration(StreamCluster.java:151)
at com.vertica.solutions.kafka.model.StreamCluster.setFromMapAndValidate(StreamCluster.java:107)
at com.vertica.solutions.kafka.model.StreamModel.(StreamModel.java:89)
at com.vertica.solutions.kafka.model.StreamCluster.(StreamCluster.java:39)
at com.vertica.solutions.kafka.cli.ClusterCLI.getNewModel(ClusterCLI.java:47)
at com.vertica.solutions.kafka.cli.ClusterCLI.getNewModel(ClusterCLI.java:13)
at com.vertica.solutions.kafka.cli.CLI.run(CLI.java:56)
at com.vertica.solutions.kafka.cli.CLI._main(CLI.java:132)
at com.vertica.solutions.kafka.cli.ClusterCLI.main(ClusterCLI.java:19)
Caused by: java.sql.SQLSyntaxErrorException: [Vertica]VJDBC ERROR: Function KafkaCheckBrokers() does not exist, or permission is denied for KafkaCheckBrokers()
at com.vertica.util.ServerErrorData.buildException(Unknown Source)
at com.vertica.dataengine.VQueryExecutor.executeSimpleProtocol(Unknown Source)
at com.vertica.dataengine.VQueryExecutor.execute(Unknown Source)
at com.vertica.jdbc.common.SStatement.executeNoParams(Unknown Source)
at com.vertica.jdbc.common.SStatement.executeQuery(Unknown Source)
at com.vertica.solutions.kafka.model.StreamCluster.validateConfiguration(StreamCluster.java:123)
... 8 more
Caused by: com.vertica.support.exceptions.SyntaxErrorException: [Vertica]VJDBC ERROR: Function KafkaCheckBrokers() does not exist, or permission is denied for KafkaCheckBrokers()
... 14 more

SruthiA

Please try installing kafka package and try to run the vkconfig statement.

admintools -t install_package -d db-name -p password -P kafka --force-reinstall

mdkarkeys

thank you so much. That worked like a charm