Please set the zookeeper property to the consumer of Kafka Input Operator using parameter dt.operator.<Kafka-Input-Operator-Name>.prop.consumer.zookeeper.
On Mon, Aug 29, 2016 at 6:44 PM, JOHN, BIBIN <[email protected]> wrote: > > > > > *I am using 3.4.0* > > > > > > > > *From:* Chaitanya Chebolu [mailto:[email protected]] > *Sent:* Monday, August 29, 2016 4:44 AM > *To:* [email protected] > *Subject:* Re: Issue when Launching apps having KafkaInput > > > > Hi John, > > > > From the debug message, value of zookeeperMap is null. You need to set > the zookeeper property. > > Which version of Malhar are you using? > > > > Regards, > > Chaitanya > > > > On Mon, Aug 29, 2016 at 3:15 PM, JOHN, BIBIN <[email protected]> wrote: > > Team, > > Could you please help me to debug this issue? > > > > > > An error occurred trying to launch the application. Server message: > javax.validation.ConstraintViolationException: Operator kafkainput > violates constraints [ConstraintViolationImpl{ > rootBean=com.att.dti.dtdemo1.app.Application$KafkaInput@5a04a4b6, > propertyPath='consumer.zookeeperMap', message='may not be null', > leafBean=com.datatorrent.contrib.kafka.SimpleKafkaConsumer@768e3249, > value=null}] at > com.datatorrent.stram.plan.logical.LogicalPlan.validate(LogicalPlan.java:1674) > at com.datatorrent.stram.StramClient.<init>(StramClient.java:163) at > com.datatorrent.stram.client.StramAppLauncher.launchApp(StramAppLauncher.java:596) > at com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:2056) > at com.datatorrent.stram.cli.ApexCli.launchAppPackage(ApexCli.java:3445) > at com.datatorrent.stram.cli.ApexCli.access$7400(ApexCli.java:151) at > com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:1900) > at com.datatorrent.stram.cli.ApexCli$3.run(ApexCli.java:1462) > > > > > > > > *Thanks and Regards,* > > *Bibin John| Data Movement Technology Development* > > *20205 North Creek Pkwy , Bothell, WA 98011 USA* > > *(* *Office: (770) 235 5614 | Cell: (469) 648-9858* > > *Email: *[email protected] > > > > OOO Alert : 09/19/2016 – 10/14/2016 > > > > > > > > >
