thank you for your project,
this really help me in kafka producer and consumer. but I also want to use this with kafka stream which is implement org.apache.kafka.common.serialization.Serde.
so, Do you have any plan to support that ? or I can help you write that part, I just need some help for starting point.

Hi

First of all thanks so much for this library, it will make interacting with the Confluent stack so much simpler for us. I am having trouble getting a simple example of this working with clj-kafka however. Here is an example of a sample producer code:

(defn send-msg []
  (let [schema (:schema (reg/get-latest-schema-by-subject schema-registry "Person"))]
    (with-open [p (p/producer {"bootstrap.servers" "kafka1:9092"} (ser/->avro-serializer schema-registry schema) (ser/->avro-serializer schema-registry schema))]
     (p/send p (p/record "avro-test" ["Conor"])))))

This seems to make the call to get the schema correctly, but then once it tries to send the message it looks like it makes another call in the "serialize" method to POST a new version of the schema. This call is returning a 422. I am just wondering if you would know why this is or have a way to increase the logging so I could determine the issue:

kafka-schema-registry_1 | [2017-10-27 18:59:23,600] INFO 172.21.0.1 - - [27/Oct/2017:18:59:23 +0000] "GET /subjects/Person/versions/latest HTTP/1.1" 200 185 3 (io.confluent.rest-utils.requests) kafka-schema-registry_1 | [2017-10-27 18:59:23,819] INFO 172.21.0.1 - - [27/Oct/2017:18:59:23 +0000] "POST /subjects/avro-test-value/versions HTTP/1.1" 422 71 6 (io.confluent.rest-utils.requests)

`(send-msg)
2017-10-27 14:59:23 INFO ProducerConfig:113 - ProducerConfig values:
compression.type = none
metric.reporters = []
metadata.max.age.ms = 300000
metadata.fetch.timeout.ms = 60000
acks = 1
batch.size = 16384
reconnect.backoff.ms = 10
bootstrap.servers = [kafka1:9092]
receive.buffer.bytes = 32768
retry.backoff.ms = 100
buffer.memory = 33554432
timeout.ms = 30000
key.serializer = class kafka_avro_confluent.serializers.AvroSerializer
retries = 0
max.request.size = 1048576
block.on.buffer.full = true
value.serializer = class kafka_avro_confluent.serializers.AvroSerializer
metrics.sample.window.ms = 30000
send.buffer.bytes = 131072
max.in.flight.requests.per.connection = 5
metrics.num.samples = 2
linger.ms = 0
client.id =

2017-10-27 14:59:23 WARN ProducerConfig:121 - The configuration value.serializer = class kafka_avro_confluent.serializers.AvroSerializer was supplied but isn't a known config.
2017-10-27 14:59:23 WARN ProducerConfig:121 - The configuration key.serializer = class kafka_avro_confluent.serializers.AvroSerializer was supplied but isn't a known config.
ExceptionInfo clj-http: status 422 slingshot.support/stack-trace (support.clj:201)
`