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

0
0

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据,Flink助力轻松提薪;尚未入行,让你弯道超车

1000 学习 · 225 问题

查看课程