flink往kafka中写元组数据，如何配置

Question

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
        ));

Answer 1

Michael_PK 2022-08-31 20:51:12

你对应你的flink版本，比如是1.13的，参考官网的https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/#kafka-producer