【flink】之kafka到kafka-2.配置Kafka数据源： Properties properties = new Properties; properties.setProperty("bootstrap.servers", "your_kafka_broker:9092"); properties.setProperty("group.id", "flink_consumer_group"); FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>( "source_topic", // Kafka source topic new SimpleStringSchema, // 数据反序列化方式 properties ); DataStream&l

2024-10-30 07:19:55