Hi Srikanth, Below dependency also doesn't work. Because the abstract operator is under kafka-common module. <dependency> <groupId>org.apache.apex</groupId> <artifactId>malhar-kafka</artifactId> <version>3.8.0-SNAPSHOT</version> <exclusions> <exclusion> <groupId>*</groupId> <artifactId>*</artifactId> </exclusion> </exclusions> </dependency>
You need to include the dependency as follows: <dependency> <groupId>org.apache.apex</groupId> <artifactId>malhar-kafka</artifactId> <version>3.8.0-SNAPSHOT</version> <exclusions> <exclusion> <groupId>org.apache.apex</groupId> <artifactId>malhar-library</artifactId> </exclusion> </exclusions> </dependency> (or) <dependency> <groupId>org.apache.apex</groupId> <artifactId>malhar-kafka</artifactId> <version>3.8.0-SNAPSHOT</version> </dependency> Regards, On Fri, Aug 11, 2017 at 6:26 AM, Vinay Bangalore Srikanth (JIRA) < [email protected]> wrote: > > [ https://issues.apache.org/jira/browse/APEXMALHAR-2537? > page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel& > focusedCommentId=16122624#comment-16122624 ] > > Vinay Bangalore Srikanth commented on APEXMALHAR-2537: > ------------------------------------------------------ > > Update: > <dependency> > <groupId>org.apache.apex</groupId> > <artifactId>malhar-kafka010</artifactId> > <version>3.8.0-SNAPSHOT</version> > </dependency> works. > > <dependency> > <groupId>org.apache.apex</groupId> > <artifactId>malhar-kafka010</artifactId> > <version>3.8.0-SNAPSHOT</version> > <exclusions> > <exclusion> > <groupId>*</groupId> > <artifactId>*</artifactId> > </exclusion> > </exclusions> > </dependency> does not work > > > <dependency> > <groupId>org.apache.apex</groupId> > <artifactId>malhar-kafka</artifactId> > <version>3.8.0-SNAPSHOT</version> > <exclusions> > <exclusion> > <groupId>*</groupId> > <artifactId>*</artifactId> > </exclusion> > </exclusions> > </dependency> works! > > Just wondering why this difference between two kafka versions. > > > POM bundling issue in apex-malhar/kafka/kafka010 > > ------------------------------------------------ > > > > Key: APEXMALHAR-2537 > > URL: https://issues.apache.org/ > jira/browse/APEXMALHAR-2537 > > Project: Apache Apex Malhar > > Issue Type: Bug > > Reporter: Vinay Bangalore Srikanth > > > > This error is seen in the file - > > *_org.apache.apex.malhar.kafka.AbstractKafkaInputOperator > cannot be resolved. It is indirectly referenced from required .class files_* > > Even though, I have included this in the pom.xml > > <dependency> > > <groupId>org.apache.apex</groupId> > > <artifactId>malhar-kafka010</artifactId> > > <version>3.8.0-SNAPSHOT</version> > > <exclusions> > > <exclusion> > > <groupId>*</groupId> > > <artifactId>*</artifactId> > > </exclusion> > > </exclusions> > > </dependency> > > I had to add this explicitly to resolve - > > <dependency> > > <groupId>org.apache.apex</groupId> > > <artifactId>malhar-kafka-common</artifactId> > > <version>3.8.0-SNAPSHOT</version> > > <exclusions> > > <exclusion> > > <groupId>org.apache.kafka</groupId> > > <artifactId>kafka_2.11</artifactId> > > </exclusion> > > </exclusions> > > </dependency> > > However, I don't see such issue with - > > <dependency> > > <groupId>org.apache.apex</groupId> > > <artifactId>malhar-kafka</artifactId> > > <version>${malhar.version}</version> > > <exclusions> > > <exclusion> > > <groupId>*</groupId> > > <artifactId>*</artifactId> > > </exclusion> > > </exclusions> > > </dependency> > > > > -- > This message was sent by Atlassian JIRA > (v6.4.14#64029) > -- *Chaitanya* Software Engineer E: [email protected] | Twitter: @chaithu1403 www.datatorrent.com | apex.apache.org
