Почему при переделке API StoreName не было указано в методе таблицы Kafka StreamsBuilder?

Question

В Kafka StreamsBuilder подпись только для таблицы:

table(java.lang.String topic)

https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/StreamsBuilder.html

Где, как и раньше, вы могли указать название магазина:

table(java.lang.String topic, java.lang.String queryableStoreName)

https://kafka.apache.org/0110/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html

Почему это было удалено?

Answer 1

Не был удален, но API был переработан. Пожалуйста, прочтите примечания по обновлению для изменений API: https://kafka.apache.org/11/documentation/streams/upgrade-guide

Для этого изменения, в частности, полная информация документирована через KIP-182: https://cwiki.apache.org/confluence/display/KAFKA/KIP-182%3A+Reduce+Streams+DSL+overloads+and+allow+easier+use+of+custom+storage+engines

Теперь вы можете указать название магазина через параметр Materialized:

table(String topic, Materialized materialized);