Options
How to solve this error when i use KafkaExport
HyeontaeJu
Vertica Customer ✭
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
0
Answers
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 ();
@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.