Hi all;
I use kafka 0.9.0.1.
I publish 10 messages to my kafka server, but when i try to use my
consumer, it does not retriev any messages.
In the following code snippet, it prints 111 and 222 and thread runs
forever without sending any records :(

I set consumer.timeout property, but nothing helps me..

Can anybody help me?

public void run() {

try {

consumer.subscribe(topics);

System.out.println("111");

while (true) {

System.out.println("2222");

ConsumerRecords<String, RawFile> records = consumer.poll(100);

System.out.println("3333 : "+records.count());

for (ConsumerRecord<String, RawFile> record : records) {

System.out.println("4444");

FileProcessor processor = new FileProcessor();

processor.processFile(record.value());


}

}


} catch (Throwable e) {

e.printStackTrace();

System.out.println("eror in polling");


} finally {

consumer.close();

}

}
-- 
-Ratha
http://vvratha.blogspot.com/

Reply via email to