dangkaka/go-kafka-avro

A library provides consumer/producer to work with kafka, avro and schema registry

go-kafka-avro's Issues

TLS Kafka example

I am having trouble figuring out how to create a TLS Kafka client using a schema registry with your library. I am hoping you can help me w/ an example since the docs are a little bit thin in this regard. Thanks again !

Cannot connect to remote kafka server

I have tried using the example producer provided in the repoistory although I couldn't produce to remote kafka. And I get the following error:
Could not add a msg: dial tcp 127.0.0.1:29092: connect: connection refused

Connection configurations:

var kafkaServers = []string{"192.168.1.2:29092"}
var schemaRegistryServers = []string{"http://192.168.1.2:18088"}

Am I missing something, or connecting to remote kafka isn't supported?
Thanks in advance.

Deprecation of github.com/bsm/sarama-cluster

Describe the bug
With the deprecation of github.com/bsm/sarama-cluster in favor of the Sarama driver implementation, the library now generates and error when used.

Expected behavior
The library should compile without error

Screenshots

Additional context
Add any other context about the problem here.

License?

What is the license of this project?

Can we use portions from it under Apache License v2?