本帖最后由 pig2 于 2016-12-19 20:14 编辑 第一个问题: 应该是新旧api的问题。 在0.7版本是 import kafka.javaapi.producer.producer 0.8应该是过度 kafka0.9及kafka 0.10.0.1 API import org.apache.kafka.clients.producer.Producer; 楼主可以留意版本 api相关链接 https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html |
pig2 发表于 2016-12-19 20:07 谢谢您的回答,我一般看到您的贴,我就认为是最官方的回答!!谢谢,谢谢 |
easthome001 发表于 2016-12-19 20:22 maven 呢 |
这个是那个网站的,没有找到啊 |
第一个问题我也不是特别清楚 第二个问题是说选择scala 2.10版本的kafka还是scala 2.11版本的kafka 第三个问题kafka_2.10和kafka_2.11表示使用的scala版本,kafka-clients应该是kafka提供的客户端api,看你代码里需不需要用到,来决定是否导入 |