[ https://issues.apache.org/jira/browse/SAMZA-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xinyu Liu reassigned SAMZA-1592: -------------------------------- Assignee: Xinyu Liu > Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza > --------------------------------------------------------------------- > > Key: SAMZA-1592 > URL: https://issues.apache.org/jira/browse/SAMZA-1592 > Project: Samza > Issue Type: Bug > Reporter: Jagadish > Assignee: Xinyu Liu > Priority: Major > > After the 0.11 upgrade, the latest branch in hello-samza (and hence all our > open-source tutorials that rely on it) are broken. Users who follow the > tutorial will see this error when starting their job. > > {code:java} > 2018-02-21 10:32:56.604 [main] SyncProducer [INFO] Connected to > localhost:9092 for producing > 2018-02-21 10:32:56.604 [main] ClientUtils$ [WARN] Fetching topic metadata > with correlation id 0 for topics [Set(wikipedia-stats)] from broker > [BrokerEndPoint(0,localhost,9092)] failed > java.lang.NoSuchMethodError: org.apache.kafka.common.network.NetworkSend: > method <init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V not found > at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41) > at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44) > /* > at kafka.network.BlockingChannel.send(BlockingChannel.scala:112) > at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:80) > at > kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79) > at kafka.producer.SyncProducer.send(SyncProducer.scala:124) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) > at > org.apache.samza.util.ClientUtilTopicMetadataStore.getTopicInfo(ClientUtilTopicMetadataStore.scala:37) > at > org.apache.samza.system.kafka.KafkaSystemAdmin.getTopicMetadata(KafkaSystemAdmin.scala:352) > at > org.apache.samza.system.kafka.KafkaSystemAdmin$$anonfun$getSystemStreamMetadata$2$$anonfun$9.apply(KafkaSystemAdmin.scala:230) > at > org.apache.samza.system.kafka.KafkaSystemAdmin$$anonfun$getSystemStreamMetadata$2$$anonfun$9.apply(KafkaSystemAdmin.scala:230) > at > org.apache.samza.system.kafka.TopicMetadataCache$.getTopicMetadata(TopicMetadataCache.scala:52) > at > org.apache.samza.system.kafka.KafkaSystemAdmin$$anonfun$getSystemStreamMetadata$2.apply(KafkaSystemAdmin.scala:227) > at > org.apache.samza.system.kafka.KafkaSystemAdmin$$anonfun$getSystemStreamMetadata$2.apply(KafkaSystemAdmin.scala:226) > at > org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:83) > at > org.apache.samza.system.kafka.KafkaSystemAdmin.getSystemStreamMetadata(KafkaSystemAdmin.scala:225) > at > org.apache.samza.system.kafka.KafkaSystemAdmin.getSystemStreamMetadata(KafkaSystemAdmin.scala:213) > at > org.apache.samza.execution.StreamManager.getStreamPartitionCounts(StreamManager.java:82) > at > org.apache.samza.execution.ExecutionPlanner.updateExistingPartitions(ExecutionPlanner.java:163) > at org.apache.samza.execution.ExecutionPlanner.plan(ExecutionPlanner.java:71) > at > org.apache.samza.runtime.AbstractApplicationRunner.getExecutionPlan(AbstractApplicationRunner.java:146) > at > org.apache.samza.runtime.AbstractApplicationRunner.getExecutionPlan(AbstractApplicationRunner.java:124) > at > org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:152) > at > samza.examples.wikipedia.application.WikipediaZkLocalApplication.main(WikipediaZkLocalApplication.java:51) > {code} > While open-source moved on to using Kafka-0.11, the hello-samza tutorial > still relies on Kafka 0.10. The fix is to make both these Kafka versions > consistent by updating the hello-samza tutorial to use Kafka 0.11 -- This message was sent by Atlassian JIRA (v7.6.3#76005)