案例准备：

1、启动zookeeper
2、启动Kafka
3、打开IDEA

案例需求：

需求：使用flink写入数据到Kafka

代码实现：

def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(1)

    val stream = env.fromElements(
      "hello",
      "world"
    )

    stream.addSink(new FlinkKafkaProducer011[String](
      "192.168.91.180:9092",
      "mydemo",
      new SimpleStringSchema()
      ))

    env.execute()
  }

消费者消费信息：

kafka-console-consumer.sh --bootstrap-server 192.168.91.180:9092 --topic mydemo --from-beginning

运行结果：