integration with apache kafka Error getting metadata

Hello,
Could you please help me with the following issue?
I have installed kafka cluster with configured authentication and I try to integrate it with vertica. From database client (connect to DB from admintools) queries to kafka cluster performed without problems, for example, KafkaCheckBrokers or kafkalistTopics:
json_test2=> SELECT kafkalistTopics(USING PARAMETERS
json_test2(> brokers='192.168.0.8:9093',
json_test2(> kafka_conf='sasl.username=myusername;sasl.password=mypassword;sasl.mechanism=SCRAM-SHA-512;security.protocol=SASL_PLAINTEXT'
json_test2(> ) OVER ();
topic | num_partitions
---------+----------------
mytest | 1
(1 row)

But when I try to create cluster from vkconfig:
vkconfig cluster --create --cluster kafka_weblog_json --hosts 192.168.0.8:9093, 192.168.0.7:9093,192.168.0.9:9093 --conf /opt/vertica/packages/kafka/config/file.conf
(I use the same authentication parameters, I add them at configuration file file.conf), I get error "Error getting metadata: [Local: Timed out]". What did I do wrong?
This is my configuration file file.conf:
username=mydba
password=password
dbhost=192.168.0.5
dbport=5433
config-schema=weblog_sched_json
sasl.username=myusername
sasl.password=mypassword
sasl.mechanism=SCRAM-SHA-512
security.protocol=SASL_PLAINTEXT

Tagged:

Best Answer

Answers

Leave a Comment

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

Can't find what you're looking for? Search the Vertica Documentation, Knowledge Base, or Blog for more information.