kafka.javaapi.consumer.ConsumerConnector vs org.apache.kafka.clients.consumer.KafkaConsumer

[Francesco Nobilia]

I'm new in Kafka and Confluent Platform. I was wondering what are the differences between these two code examples. Which is better for consuming Kafka topics inside Confluent Platform?

kafka.javaapi.consumer.ConsumerConnector consumer = kafka.consumer.Consumer.createJavaConsumerConnector(new ConsumerConfig(config));

kafka.consumer.KafkaStream KafkaStream stream = consumer.createMessageStreams(topicCountMap, stringDecoder, avroDecoder).get(inputTopic).get(0);

ConsumerIterator it = stream.iterator();

while (it.hasNext()) {}

org.apache.kafka.clients.consumer.KafkaConsumer consumer = new KafkaConsumer<K, V>(config);

while (running) {

  ConsumerRecords<K, V> records = consumer.poll(Long.MAX_VALUE);

  process(records);

  consumer.commitSync();

}

the first one has been copied from here https://github.com/confluentinc/examples/tree/kafka-0.10.0.1-cp-3.0.1/kafka-clients/specific-avro-consumer, while the second from http://docs.confluent.io/3.0.1/clients/consumer.html.

Thank you in advance.

Francesco

[kevin]

Hello ,

I would like to get the clear answer regarding this topic. Did you get any answer regarding your question?

Thanks