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
> >>
> >>
>
>
