title: Flink with Kafka Consumer doesn't work
body: <p>I want to benchmark Spark vs Flink, for this purpose I am making several tests. However Flink doesn't work with Kafka, meanwhile with Spark works perfect.</p>
  
  <p>The code is very simple: </p>
  
  <pre><code>val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
  
  val properties = new Properties()
  properties.setProperty("bootstrap.servers", "localhost:9092")
  properties.setProperty("group.id", "myGroup")
  println("topic: "+args(0))
  val stream = env.addSource(new FlinkKafkaConsumer09[String](args(0), new SimpleStringSchema(), properties))
  stream.print
  
  env.execute()
  </code></pre>
  
  <p>I use kafka 0.9.0.0 with the same topics (in consumer[Flink] and producer[Kafka console]), but when I send my jar to the cluster, nothing happens:</p>
  
  <p><a href="http://i.stack.imgur.com/rm1i1.png" rel="nofollow">Cluster Flink</a></p>
  
  <p>What it could be happening? </p>