Are you using the 0.8.2 release or trunk? -Jay
On Mon, Mar 30, 2015 at 1:35 AM, Sandeep Bishnoi < sandeepbishnoi.b...@gmail.com> wrote: > Hi, > > I have configured a kafka consumer as follows: > Properties props = new Properties(); > // ...... > // Populated properties > KafkaConsumer consumer = new KafkaConsumer(props); > > // subscribe to partition "0" of topic test > TopicPartition partition0 = new TopicPartition("test", 0); > TopicPartition[] partitions = new TopicPartition[1]; > partitions[0] = partition0; > consumer.subscribe(partitions); > System.out.println("Created consumer " + consumer); > > Consumer is getting created without any errors. > > Now I am following instructions on how to read from a partition using > > http://kafka.apache.org/083/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html > . > > Here is a code snippet for the same: > > boolean isRunning = true; > Map<TopicPartition, Long> consumedOffsets = new HashMap<TopicPartition, > Long>(); > while(isRunning) > { > Map<String, ConsumerRecords<byte[], byte[]>> records = > consumer.poll(100); > ....... > ..... > > The consumer.poll() api is returning null always. Although the remaining > code is based on the returned value from poll. > > Can you please let me know whether > org.apache.kafka.clients.consumer.KafkaConsumer is a valid API to use if I > want to create a client which can read from a given partition of a given > topic. > > Best Regards, > Sandeep >