[
https://issues.apache.org/jira/browse/KAFKA-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15090894#comment-15090894
]
Praveen Devarao edited comment on KAFKA-3044 at 1/10/16 5:23 AM:
-----------------------------------------------------------------
Had some time on hands and thought will make the doc changes. Let me know if
the wording for timeout is fine and also if any other place that needs similar
change (will make them too).
Thanks
Praveen
was (Author: praveend):
Had sometime on hands and thought will make the doc changes. Let me know if the
wording for timeout is fine and also if any other place that needs similar
change (will make them too).
Thanks
Praveen
> Consumer.poll doesnot return messages when poll interval is less
> ----------------------------------------------------------------
>
> Key: KAFKA-3044
> URL: https://issues.apache.org/jira/browse/KAFKA-3044
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 0.9.0.0
> Reporter: Praveen Devarao
> Assignee: Jason Gustafson
> Fix For: 0.9.0.1
>
>
> When seeking to particular position in consumer and starting poll with
> timeout param 0 the consumer does not come back with data though there is
> data published via a producer already. If the timeout is increased slowly in
> chunks of 100ms then at 700ms value the consumer returns back the record on
> first call to poll.
> Docs
> [http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)]
> for poll reads if timeout is 0 then data will be returned immediately but
> the behaviour seen is that data is not returned.
> The test code I am using can be found here
> https://gist.github.com/praveend/013dcab01ebb8c7e2f2d
> I have created a topic with data published as below and then running the test
> program [ConsumerPollTest.java]
> $ bin/kafka-topics.sh --create --zookeeper localhost:2181
> --replication-factor 1 --partitions 1 --topic mytopic
> $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic
> Hello
> Hai
> bye
> $ java ConsumerPollTest
> I have published this 3 lines of data to kafka only once....later on I just
> use the above program with different poll interval
> Let me know if I am missing anything and interpreting it wrongly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
