The Vertica Forum recently got a makeover! Let us know what you think by filling out this short, anonymous survey.
Please take this survey to help us learn more about how you use third party tools. Your input is greatly appreciated!

How to solve this error when i use KafkaExport

HyeontaeJuHyeontaeJu Vertica Customer

I wanna use KafkaExport function,, but when i was test the KafkaExport function I encounter this message.. what's wrong??..
my query

     KafkaExport(null, product_id::VARCHAR, product_id
         USING PARAMETERS brokers = 'localhost:9092', 
   topic='vertica_test') OVER (PARTITION BEST)

error message

SQL Error [5861] [VP001]: [Vertica][VJDBC](5861) ERROR: Error calling processPartition() in User Function KafkaExport at [src/KafkaExport.cpp:215], error code: 0, message: Error connecting to brokers localhost:9092: Local: Broker transport failure


  • SergeBSergeB - Select Field - Employee
    edited March 2021

    Do you have a local Kafka broker running on port 9092? If so, can you test with kafkacat or KafkaCheckbrokers
    /opt/vertica/packages/kafka/bin/kafkacat -L -b localhost:9092
    select KafkaCheckBrokers(using parameters brokers='localhost:9092') over ();

  • HyeontaeJuHyeontaeJu Vertica Customer
    edited March 2021

    @SergeB Thank you very mush. I set the test environment using docker.
    i resolved this issue's problem that Vertica's KafkaExtract function cannot connect to kafka topic by resetting the docker network environment.

    thank you so much comment by this issue.

Leave a Comment

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