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 <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>*
signature.asc
Description: Message signed with OpenPGP using GPGMail
