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

jkiran2020jkiran2020
in General Discussion

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.

Comments

  • Jim_KnicelyJim_Knicely - Select Field - Administrator

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

  • Ben_VandiverBen_Vandiver Employee

    Does your kafka scheduler version match the database version?

Leave a Comment

BoldItalicStrikethroughOrdered listUnordered list
Format
SpoilerCodeQuote
Heading 2Heading 1
Emoji
:):D:(;):/:o:s:p:'(:|B):#:*<3o:)>:)
Url
Image
Align leftAlign centerAlign rightToggle HTML viewToggle full pageToggle lights
Drop image/file
Home • General DiscussionComment As ...