Exception using the new createDirectStream util method

Hi all, I am trying to make the new kafka and spark streaming integration work (direct approach "no receivers" ). I have created an unit test where I configure and start both zookeeper and kafka. When I try to create the InputDS

Re: Exception using the new createDirectStream util method

setsResponse => >> if (por.error == ErrorMapping.NoError) { >> ... >> } else { >> errs.append(ErrorMapping.exceptionFor(por.error)) >> } >> There should be some error other than "Couldn't find leader offsets for >&

Re: Exception using the new createDirectStream util method

> Try putting a message in the topic and seeing what happens. > > On Thu, Mar 19, 2015 at 4:38 PM, Alberto Rodriguez > wrote: > >> Thank you for replying, >> >> Ted, I have been debuging and the getLeaderOffsets method is not appending >> errors because the m