go-kafka-avro
go-kafka-avro copied to clipboard
dangkaka
A library provides consumer/producer to work with kafka, avro and schema registry
**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...
This PR; - Adds SASL Config option to AvroProducer and AvroConsumer builder functions, with examples provided - Modifies the AvroProducer methods for increased performance - Migrates the SchemaRegistryClient code usage...
This PR fixes the failing test for the Avro producer: ``` --- FAIL: TestAvroProducer_Add (0.00s) avroProducer_test.go:17: Error adding msg: unexpected end of JSON input sync_producer.go:115: Expected to exhaust all expectations,...
This PR adds the capability to use HTTP basic authentication to connect to the schema registry. An example of a client using this code would be: ``` var schemaRegistryClient schema.SchemaRegistryClientInterface...
Merging original with my refactor
