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

Reply via email to