Sand Box ==> Retail Recommendation Example in Base_project

Anonymous — Sat, 16 Nov 2024 09:56:48 GMT

Hello,
For Standard Jobs > Realtime_Recommendation_Demo I have successfully executed the following steps:
Step_1a_Recommendation_DemoSetup 0.1
Step_1b_Recommendation_DemoSetup 0.1
When I try to execute the following step Step_2_Recommendation_Create_KafkaTopic 0.1, I get an error listed below. Can someone help on this.
****************************
connecting to socket on port 3821
connected
Exception in component tKafkaCreateTopic_1
: base_project.step_2_recommendation_create_kafkatopic_0_1.Step_2_Recommendation_Create_KafkaTopic - tKafkaCreateTopic_1 org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
    at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)
    at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:995)
    at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:675)
    at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:671)
    at kafka.utils.ZkUtils.getChildren(ZkUtils.scala:537)
    at kafka.utils.ZkUtils.getSortedBrokerList(ZkUtils.scala:172)
    at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:235)
    at kafka.admin.AdminUtils.createTopic(AdminUtils.scala)
    at base_project.step_2_recommendation_create_kafkatopic_0_1.Step_2_Recommendation_Create_KafkaTopic.tKafkaCreateTopic_1Process(Step_2_Recommendation_Create_KafkaTopic.java:313)
    at base_project.step_2_recommendation_create_kafkatopic_0_1.Step_2_Recommendation_Create_KafkaTopic.runJobInTOS(Step_2_Recommendation_Create_KafkaTopic.java:606)
    at base_project.step_2_recommendation_create_kafkatopic_0_1.Step_2_Recommendation_Create_KafkaTopic.main(Step_2_Recommendation_Create_KafkaTopic.java:434)
Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
    at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472)
    at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500)
    at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:114)
    at org.I0Itec.zkclient.ZkClient$4.call(ZkClient.java:678)
    at org.I0Itec.zkclient.ZkClient$4.call(ZkClient.java:675)
    at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:985)
    ... 9 more
disconnected
Job Step_2_Recommendation_Create_KafkaTopic ended at 09:17 02/04/2017.
****************************

topic Sand Box ==> Retail Recommendation Example in Base_project in Talend Studio

Sand Box ==> Retail Recommendation Example in Base_project