Почему источник flink kafka в таблице api не может объединиться?

Question

У меня есть несколько рабочих мест для слияния.Потому что их источник данных одинаков.Поэтому я хочу объединить их, как показано на рисунке ниже.

Я уверен, что их источник использует один и тот же объект таблицы.Я проверил исходный код Flink, но не помогло.

Есть какой-нибудь совет?Заранее спасибо.

Answer 1

С API DataStream вы можете просто сделать что-то вроде этого:

streamFromKafka = env.addSource(new FlinkKafkaConsumer<>(inputTopic, ...));

streamFromKafka
  ... // one set of operations
  .addSink(new FlinkKafkaProducer<>(outputTopic1, ...));

streamFromKafka
  ... // another set of operations
  .addSink(new FlinkKafkaProducer<>(outputTopic2, ...));

Вам придется немного отрегулировать это, чтобы использовать API таблицы, но принцип тот же.