kafkaCheckBrokers function issues

mdkarkeysmdkarkeys Registered User

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

Best Answer

Answers

Leave a Comment

BoldItalicStrikethroughOrdered listUnordered list
Emoji
Image
Align leftAlign centerAlign rightToggle HTML viewToggle full pageToggle lights
Drop image/file