How to solve this error when i use KafkaExport

HyeontaeJu

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

SergeB

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 ();

HyeontaeJu

@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.