narcisoguillen / kafka-node-avro

ISC License
26 stars 13 forks source link

Add support for confluent cloud schema registry #24

Closed Umaaz closed 3 years ago

Umaaz commented 3 years ago

We want to use your lib with confluent cloud schema registry but need to have basic auth support.

narcisoguillen commented 3 years ago

Hey @Umaaz thanks for helping make this lib better , awesome thanks, but we need to add this on the Readme and please some tests. I have had a lot of work , and few free time. I will try to help as well to make this possible as soon as possible. 🍻

narcisoguillen commented 3 years ago

https://github.com/narcisoguillen/kafka-node-avro/issues/21 tagging related issue to PR.

narcisoguillen commented 3 years ago

made it so you can set not only auth ( user/pass ) but any other option you might need , in this case you should be able to do

const Settings  = {
  kafka : {
    kafkaHost : "localhost:9092"
  },
  schema  : {
    registry : "http://localhost:8081",
    options : {
       auth : {
         user : 'username',
         pass : 'password'
       }
    }
 }
};