Thanks!
> On May 31, 2016, at 1:00 PM, Michael Noll <mich...@confluent.io> wrote: > > FYI: I fixed the docs of schema registry (vProps -> props). > > Best, Michael > > > On Tue, May 31, 2016 at 2:05 AM, Rick Mangi <r...@chartbeat.com> wrote: > >> That was exactly the problem, I found the example here to be very helpful >> - >> https://github.com/confluentinc/examples/blob/master/kafka-clients/specific-avro-consumer/src/main/java/io/confluent/examples/consumer/AvroClicksSessionizer.java >> >> IMHO it’s confusing having the same class names in different packages when >> most people probably rely on an IDE to manage their imports. >> >> Thanks! >> >> Rick >> >> >> On May 30, 2016, at 5:44 AM, Michael Noll <mich...@confluent.io> wrote: >> >> Rick, >> >> >> Is your code really importing the correct ConsumerConfig objects? >> >> It should be: >> >> import kafka.consumer.ConsumerConfig; >> >> If you are using your IDE's auto-import feature, you might however end up >> with the following import, which will give you the "ConsumerConfig is not a >> public class" compile error: >> >> import org.apache.kafka.clients.consumer.ConsumerConfig; >> >> Lastly, it looks as if you need to update the following line as well: >> >> // Note that this constructs from props (j.u.Properties), not vProps >> (VerifiableProperties) >> ConsumerConnector consumer = >> kafka.consumer.Consumer.createJavaConsumerConnector(new >> ConsumerConfig(props)); >> >> Let us know if this solves your error. The CP 3.0.0 docs might need a fix >> then (to change vProps to props). >> >> Best, >> Michael >> >> >> >> On Sun, May 29, 2016 at 2:49 PM, Rick Mangi <r...@chartbeat.com> wrote: >> >> Hello all, >> >> I’m trying to use the new schema registry to read avro encoded messages I >> created with kafka connect as described here: >> >> http://docs.confluent.io/3.0.0/schema-registry/docs/serializer-formatter.html >> >> The example code is obviously not correct, but beyond the obvious, I can’t >> seem to figure out how to register KafkaAvroDecoder with a consumer. The >> example given >> >> ConsumerConnector consumer = >> kafka.consumer.Consumer.createJavaConsumerConnector(new ConsumerConfig( >> vProps)); >> >> Is illegal, ConsumerConfig is a private class and can’t be instantiated. >> It also seems that KafkaAvroDecoder does not implement Deserializer, and >> thus can’t be used in the normal way deserializers are registered. >> >> Has anyone gotten this stuff to work? >> >> Thanks, >> >> Rick >> >> >> >> >> -- >> Best regards, >> Michael Noll >> >> >> >> *Michael G. Noll | Product Manager | Confluent | +1 650.453.5860Download >> Apache Kafka and Confluent Platform: www.confluent.io/download >> <http://www.confluent.io/download>* >> >> >> > > > -- > Best regards, > Michael Noll > > > > *Michael G. Noll | Product Manager | Confluent | +1 650.453.5860Download > Apache Kafka and Confluent Platform: www.confluent.io/download > <http://www.confluent.io/download>*
signature.asc
Description: Message signed with OpenPGP using GPGMail
