kafka KafkaStream的iterator()方法不会执行？

ConsumerIterator<byte[],byte[]> it =stream.iterator(); 这句代码老是报错,The method iterator() is ambiguous for the type KafkaStream<byte[],byte[]>...

ConsumerIterator; import kafka.consumer.KafkaStream;...在项目目录下执行mvn package命令,得到依赖包testKafka...

运行mvn package 编译代码,执行查看结果: 1 java -cp target/lib/* :target...import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; ...

import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; /** * @author leicui bourne_cui@...

import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import...在实际执行读取操纵时,首先需要定位数据所在的日志文件,然后根据offset计算出在...

import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; import kafka.serializer.StringDecoder;...

import kafka.consumer.ConsumerConfig; import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; ...

import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; public class TestConsumer...

启动,在三个节点分别执行 bin/kafka-server-start.sh config/server.properties ....ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.javaapi....

import kafka.consumer.ConsumerConfig;import kafka.consumer.ConsumerIterator;import kafka.consumer.KafkaStream;import kafka.javaapi.consumer.ConsumerConnector; /**...