Please take this survey to help us learn more about how you use third party tools. Your input is greatly appreciated!

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.