How to solve this error when i use KafkaExport

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

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

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

Answers

  • SergeBSergeB 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
    or
    select KafkaCheckBrokers(using parameters brokers='localhost:9092') over ();

  • 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
Emoji
Image
Align leftAlign centerAlign rightToggle HTML viewToggle full pageToggle lights
Drop image/file