integration with apache kafka Error getting metadata

aleksss55

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

SruthiA

@aleksss55 if the security.protocol is SASL_PLAINTEXT.. sasl.mechanism PLAIN should be used. Vertica doesnt support SCRAM-SHA-512 yet. Please find the latest 10.0 documentation link which details the same.

https://www.vertica.com/docs/10.0.x/HTML/Content/Authoring/KafkaIntegrationGuide/AuthenticatingWithKafkaUsingSASL.htm

aleksss55

Thanks a lot