sink 写入 kafka（九）

• • • 2.4.2 将数据写入 kafka （Kafka Sink）

开启消费者
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.23.97:9092 --topic kafkasink

开启服务者
./bin/kafka-console-producer.sh --broker-list 192.168.23.97:9092 --topic sensor

package com.flink.sink.study

import java.util.Prope