Hi, sorry for the extremely late follow up:
No, there is nothing logged on the broker, Using default log4j.properties. I also tried to activate trace logging for the network processor component (log4j.logger.kafka.network.Processor=TRACE, requestAppender), without seeing anything that seemed related to my problem. Thanks /Magnus > On 20 Oct 2014, at 04:49, Jun Rao <jun...@gmail.com> wrote: > > 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 >>>> >>>> >> >>