DataStreamSink 类有一个名称字段。为什么 FlinkKafkaConsumer 和 FlinkKafkaProducer 没有类似的字段？在 Flink 仪表板中，我的接收器都显示"未命名">
你只需要命名正在制作的接收器，记住生产者只是执行接收器操作的功能，但它仍然是一个DataStreamSink。
所以你只需要做
foo.addSink(yourProducer).name("Kafka: " + topic)
Flink StreamExecution Environment 中有一些选项可以添加源名称以及任何源函数。请参阅 java 文档链接。
env.add(sourceFunction，"Kafka topic"(;
Flink 流执行环境添加源名称