flink往kafka中写元组数据,如何配置
来源:4-17 【任务题】词频统计

qq_一半一伴_0
2022-08-31
flink向kafka中写数据,元组类型的序列化该如何写。没有找到对应的参数。
// kafka链接配置
Properties properties = new Properties();
properties.put("bootstrap.servers", "master:9092,node1:9092,node2:9092");
//properties.put("","");
reduce.addSink(new FlinkKafkaProducer<Tuple2<String, Long>>(
"test_topic1",
//该参数不知道该怎么写,
properties
));
写回答
1回答
-
Michael_PK
2022-08-31
你对应你的flink版本,比如是1.13的,参考官网的https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#kafka-producer
00
相似问题