Поток Kafka Присоединяется, как задать различные параметры конфигурации для левого и правого потоков - PullRequest
0 голосов
/ 30 апреля 2020
final Properties kafkaStreamConfiguration = new Properties();
kafkaStreamConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, APPLICATION_ID);
kafkaStreamConfiguration.put(StreamsConfig.CLIENT_ID_CONFIG, APPLICATION_ID);
..

final StreamsBuilder builder = new StreamsBuilder();        
//Table
KTable<String, Object> table= builder.table(TABLE_TOPIC);

//Stream
KStream<String, Object> stream= builder.stream(STREAM_TOPIC);

stream.leftJoin(table, ..);

final KafkaStreams streams = new KafkaStreams(builder.build(), kafkaStreamConfiguration);
streams.start();

Вопрос - Есть ли способ передать различные свойства kafkaStreamConfiguration в таблицу и поток?

...