如何在Kafka 0.10.1.0中使用Flink？

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka-0.10_2.11</artifactId>
    <version>${flink.version}</version>
</dependency>

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010;

import java.util.Properties;

public class KafkaFlinkExample {
    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        Properties properties = new Properties();
        properties.setProperty("bootstrap.servers", "localhost:9092");
        properties.setProperty("group.id", "flink-consumer-group");

        FlinkKafkaConsumer010<String> consumer = new FlinkKafkaConsumer010<>("my-topic", new SimpleStringSchema(), properties);

        env.addSource(consumer)
                .print();

        env.execute("Kafka Flink Example");
    }
}

mvn clean package

./bin/flink run -c com.example.KafkaFlinkExample path/to/your/jar-file.jar