我对Kafka和Samza非常陌生。我尝试了hello-samza示例,它正在工作。我正在寻找的是创建一个从卡夫卡topic.The任务读取消息的samza任务,我没有抛出任何错误,也没有从主题读取任何消息。# Kafka System
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactorysystems.
我正在运行一个Samza流作业,正在向Kafka主题写入数据。Kafka运行的是一个3节点集群。Samza作业部署在yarn上。Exiting process now.
org.apache.samza.SamzaException: org.apache.samza.SamzaException: Unable to sendby: org.apache.samza.SamzaException: Unable to send message from TaskNam
: Could not resolve dependencies for project org.apache.samza:hello-samza:jar:0.11.0: Failed to collectorg.apache.samza:samza-api:jar:0.11.0-SNAPSHOT: Could not transfer artifact org.apache.samza:samza-api/samza-api/0.11.0-SNAP