[jira] [Commented] (APEXMALHAR-2511) Kafka example fails when launched in local mode

["Thomas Weise (JIRA)" <ji...@apache.org>]

    [ 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)