Re: no new topic created on Kafka

Hi, Yan: Thanks for fixing the bug for me. Sincerely, Selina On Tue, Jul 28, 2015 at 12:03 PM, Yan Fang wrote: > task.class=samza.http.demo.task.HttpDemoParserStreamTask ... > > you are not using the StateStream class... > > Fang, Yan > yanfang...@gmail.com > > On Tue, Jul 28, 2015 at 11

Re: no new topic created on Kafka

task.class=samza.http.demo.task.HttpDemoParserStreamTask ... you are not using the StateStream class... Fang, Yan yanfang...@gmail.com On Tue, Jul 28, 2015 at 11:48 AM, Job-Selina Wu wrote: > Hi, Yan > > I like to correct my previous comment, when I comment out > systems.kafka.streams.http-de

Re: no new topic created on Kafka

Hi, Yan I like to correct my previous comment, when I comment out systems.kafka.streams.http-demo.samza.offset.default=oldest systems.kafka.streams.http-demo.samza.reset.offset=true *the logger is not show at *at samza-container-0.log, but it make sense. Sincerely, Seina On Tue, Jul 28, 2015 a

Re: no new topic created on Kafka

Hi, Yan: Thanks a lot for your reply. I tried to comment out systems.kafka.http-demo.samza.offset.default=oldest and then I tried to comment out systems.kafka.streams.http-demo.samza.offset.default=oldest systems.kafka.streams.http-demo.samza.reset.offset=true The result is same as be

Re: no new topic created on Kafka

Can you comment out "systems.kafka.http-demo.samza.offset.default=oldest" to see how it works? This seems not a correct property. Thanks, Fang, Yan yanfang...@gmail.com On Mon, Jul 27, 2015 at 5:54 PM, Job-Selina Wu wrote: > Hi, Dear All: > >I have two Tasks at Samza. HttpDemoParserSt