getOffsetsBefore(...) => kafka.common.UnknownException

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

Re: getOffsetsBefore(...) => kafka.common.UnknownException

; > 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. &

Re: getOffsetsBefore(...) => kafka.common.UnknownException

1MB). > > 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. >>

FetchRequestBuilder.maxWait: request for clarification

Hi, The method kafka.api.FetchRequestBuilder.maxWait(maxwait: Int) does not give the result I would have expected. I have not been able to find any documentation or clarification on the method’s meaning. My assumption is: If I send a fetch request for messages after offset X for a partition wh

Re: getOffsetsBefore(...) => kafka.common.UnknownException

related to my problem. Thanks /Magnus > On 20 Oct 2014, at 04:49, Jun Rao 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...@digitalro

Significance of SimpleConsumer id string

Hi, The kafka.consumer.SimpleConsumer takes an "id: String” constructor parameter. What is the significance of this id? Are there any consequences or risks associated with using the exact same id for several consumers of the same topic/partition? /Magnus