I have single node data torrent/Apex installation. Software installed under
"/opt/datatorrent/releases/3.2.0”. When I uploaded and launched my application
I get error finding the class “KafkaSinglePortStringInputOperator”. I could
compile the application after adding the dt-contrib dependency
Suhas,
Do not copy any operator libraries into the lib folder. These dependencies
need to be packaged with the application into the .apa application package.
The .apa will also need to contain the Kafka dependencies.
Can you please share what .jar files are in your app package (unzip -l
yourapp.a
Thanks for the reply Thomas! I was just trying to workaround the problem
although I agree that all dependencies should be part application package.
Here is info.
Sumedhas-MacBook-Pro-2:Downloads sumedhag$ unzip -t AdStream-1.0-SNAPSHOT.apa
Archive: AdStream-1.0-SNAPSHOT.apa
testing: M
malhar-contrib and Kafka dependencies are missing.
On Mon, Feb 29, 2016 at 9:32 PM, Suhas Gogate wrote:
> Thanks for the reply Thomas! I was just trying to workaround the problem
> although I agree that all dependencies should be part application package.
> Here is info.
>
> Sumedhas-MacBook-P
How to add those dependencies? I followed the documentation of Kafka Input
Operator, created a simple java maven project, compiled to create .apa package.
So not sure how to add the malhar-contrib library in the application package?
Thanks for the help
—Suhas
From: Thomas Weise mailto:thomas.w
Example here:
https://github.com/tweise/apex-samples/blob/master/exactly-once/pom.xml
On Mon, Feb 29, 2016 at 9:36 PM, Suhas Gogate wrote:
> How to add those dependencies? I followed the documentation of Kafka Input
> Operator, created a simple java maven project, compiled to create .apa
> pac
Thanks Thomas! I could get the dependency right, but now stuck with some other
problem :) Not sure how to fix this? Appreciate your help!
An error occurred trying to launch the application. Server message:
javax.validation.ConstraintViolationException: Operator MessageReader violates
constra
Hi Suhas,
I think you have not set mandatory properties to configure Kafka operator.
Try making below changes to your DAG configuration code.
KafkaSinglePortStringInputOperator kafakOperator = new
KafkaSinglePortStringInputOperator();
KafkaConsumer consumer = new SimpleKafkaConsumer();
consume
