API потоков Кафки: Избегайте дополнительного хранилища состояний в KTable.mapValues

#apache-kafka #apache-kafka-streams #ktable Вопрос: В настоящее время мы используем следующее в нашем приложении Kafka Streams: streamsBuilder.table(inputTopic) .join(...) .mapValues(valueMapper) // <-- this causes another state store .groupBy(...) .aggregate(...) .mapValues(...) [...] .toStream()…