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>*
