Хотя Kafka Streams предоставляет очень широкие возможности настройки и множество свойств, которые можно менять под свои нужды, в нашем первом примере будут использоваться только два параметра конфигурации — APPLICATION_ID_CONFIG и BOOTSTRAP_SERVERS_CONFIG:
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "yelling_app_id");
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
Kafka Streams в действии. Приложения и микросервисы для работы в реальном времени
·
Билл Беджек
