I have tested kafka 0.8.0.2 with flink 1.0.0 and it works for me. Can't talk about kafka 0.9.0.1.
On Wed, Mar 30, 2016 at 12:51 PM, Zhun Shen <shenzhunal...@gmail.com> wrote: > Hi there, > > flink version: 1.0.0 > kafka version: 0.9.0.0 > env: local > > I run the script below: > ./bin/flink run -c com.test.flink.FlinkTest test.jar --topic nginx-logs > --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 -- > group.id myGroup --partition.assignment.strategy round robin > > But I got the error: > ava.lang.NoSuchMethodError: > org.apache.kafka.clients.consumer.KafkaConsumer.partitionsFor(Ljava/lang/String;)Ljava/util/List; > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.<init>(FlinkKafkaConsumer09.java:194) > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.<init>(FlinkKafkaConsumer09.java:164) > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.<init>(FlinkKafkaConsumer09.java:131) > > > The code as below: > DataStream<String> messageStream = env.addSource(new > FlinkKafkaConsumer09<>("nginx-logs", new > SimpleStringSchema(),parameterTool.getProperties())); > messageStream.rebalance().map(new MapFunction<String, String>() { > > @Override > public String map(String value) throws Exception { > return "Kafka and Flink says: " + value; > } > }).print(); > > > I check the error with google, but it shows that it is a method of kafka > 0.9.01. Any idea? Thanks. > >