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
