[
https://issues.apache.org/jira/browse/APEXMALHAR-2511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16063198#comment-16063198
]
Thomas Weise commented on APEXMALHAR-2511:
------------------------------------------
{code}
17/06/26 14:51:18 ERROR cli.ApexCli: Exception caught:
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:624)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:518)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:500)
at
org.apache.apex.malhar.kafka.AbstractKafkaPartitioner.initMetadataClients(AbstractKafkaPartitioner.java:235)
at
org.apache.apex.malhar.kafka.AbstractKafkaPartitioner.definePartitions(AbstractKafkaPartitioner.java:91)
at
org.apache.apex.malhar.kafka.AbstractKafkaInputOperator.definePartitions(AbstractKafkaInputOperator.java:375)
at
com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:748)
at
com.datatorrent.stram.plan.physical.PhysicalPlan.addLogicalOperator(PhysicalPlan.java:1669)
at
com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:378)
at
com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:425)
at
com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:413)
at
com.datatorrent.stram.StramLocalCluster.<init>(StramLocalCluster.java:314)
at
com.datatorrent.stram.client.StramAppLauncher.runLocal(StramAppLauncher.java:532)
at
com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:2143)
at com.datatorrent.stram.cli.ApexCli.launchAppPackage(ApexCli.java:3561)
at com.datatorrent.stram.cli.ApexCli.access$7400(ApexCli.java:153)
at
com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:1980)
at com.datatorrent.stram.cli.ApexCli$3.run(ApexCli.java:1539)
Caused by: java.lang.ClassCastException: class
org.apache.kafka.clients.consumer.RangeAssignor
at java.lang.Class.asSubclass(Class.java:3218)
at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:328)
at
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:202)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:566)
... 17 more
{code}
> Kafka example fails when launched in local mode
> -----------------------------------------------
>
> Key: APEXMALHAR-2511
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2511
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Thomas Weise
>
> Kafka to HDFS example fails when launched from the CLI with -local
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
