Do you see any WARN for the offset request on the broker? Thanks,
Jun On Fri, Oct 17, 2014 at 4:44 AM, Magnus Vojbacke < magnus.vojba...@digitalroute.com> wrote: > Yes, I used TopicMetaDataRequest to determine the lead broker for the > partition. > > I’ve also compared the broker selected by my code with the output from > "bin/kafka-topics.sh --describe[...]" and as far as I can tell, it’s using > the broker which is described as leader for the topic. > > /Magnus > > > On 17 Oct 2014, at 05:55, Jun Rao <jun...@gmail.com> wrote: > > > The OffsetRequest can only be answered by the leader of the partition. > Did > > you connect the SimpleConsumer to the leader broker? If not, you need to > > use TopicMetadataRequest to find out the leader broker first. > > > > Thanks, > > > > Jun > > > > On Thu, Oct 16, 2014 at 3:56 AM, Magnus Vojbacke < > > magnus.vojba...@digitalroute.com> wrote: > > > >> Hi, > >> > >> I’m trying to make a request for offset information from my broker, and > I > >> get a kafka.common.UnknownException as the result. > >> > >> I’m trying to use the Simple Consumer API > >> > >> > >> > >> val topicAndPartition = new TopicAndPartition(“topic3”, 0) > >> val requestInfo = new java.util.HashMap[TopicAndPartition, > >> PartitionOffsetRequestInfo]() > >> requestInfo.put(topicAndPartition, new > >> PartitionOffsetRequestInfo(kafka.api.OffsetRequest.EarliestTime, 1)) > >> > >> val request = new kafka.javaapi.OffsetRequest(requestInfo, > >> kafka.api.OffsetRequest.CurrentVersion, clientName) > >> > >> import kafka.javaapi._ > >> // conn: kafka.javaapi.consumer.SimpleConsumer > >> val response: OffsetResponse = conn.getOffsetsBefore(request) > >> > >> println("got response [" + response + “]") > >> > >> > >> > >> Output: > >> got response [OffsetResponse(0,Map([test3,1] -> error: > >> kafka.common.UnknownException offsets: 0))] > >> > >> > >> I really can’t figure out why I’m getting this response. As far as I > know, > >> “topic3” with partition “0” exists on the broker, and I can use > >> bin/kafka-console-consumer.sh to consume from it without any problems. > >> > >> > >> Is there any idea of what could cause this exception? > >> > >> As it is right now, I’m not even sure if the request gets to the broker. > >> Is there any way of activating more verbose logs on the broker? > >> > >> I think I’m using a trunk build (2.10-0.8.3-SNAPSHOT) > >> > >> > >> BR > >> /Magnus > >> > >> > >