Use connector for loading data from kafka (custom broker) to PG

[ctulurus]

Hi
I am not very familiar with node js but I want to use this connector for a reading brokers and an insertind data into postgers. I have custom message inside brokers. It looks like {"symbol":"GOOG","close":"973.4850","lag":8}. I have read README.md but I didn't understand how to use connector for my task.
Could you write READE.md more detail about use custom broker and describe your test example.

[krystianity]

Hi @ctulurus in this case you are looking at the sink connector solution.
The only thing you have to do is write a single JS file to call the runSinkConnector function and pass in the config (to connect to your Kafka cluster/broker as well as PostgresDB) and the second thing you need is an ETL function that you also have to pass to the runSinkConnector function, which defines the process of turning your Kafka message/event into a PostgresDB row for the table your are aiming at.

I might find the time to write a detailed example..

[saranOn]

Hi @krystianity
I am calling the runSinkConnector function and runSinkConnector is executed but data is not getting inserted in the table
I have ETL function and it's not being called.