Есть ли способ отделить тематические кафки от материализованных? - PullRequest
Новая
       5

Есть ли способ отделить тематические кафки от материализованных?

0 голосов
/ 24 декабря 2018

Я хотел бы отделить формат кодирования в теме Kafka от формата кодирования, используемого для локального кэширования данных в приложении потоков Kafka.Есть ли способ сделать это, который не требует от меня создания дополнительного шага (kafka-topic)?

Входная тема - тема в формате таблицы, означающая, что нулевое значение для ключа должно удалитьзапись в итоговой таблице.

Я обнаружил, что отсутствует следующая опция из-за необходимого дополнительного шага: 

s1 = builder.stream("input-topic", Consumed.with(inputKeySerde, inputValueSerde));
s2 = s1.through("intermediate-topic",  Produced.with(intermediateKeySerde, intermediateValueSerde));
t1 = builder.table("intermediate-topic", Consumed.with(intermediateKeySerde, intermediateValueSerde), t1Materialized);

Альтернативой может быть использование API процессора и простая пересылка записей в хранилище.Однако это может создать дополнительную внутреннюю тему журнала изменений.

Есть ли альтернатива, которая не требует от меня создания дополнительного шага?

...