Станиславcard.quotedөткен ай
Хотя 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 с неопределенными значениями этих двух свойств приведет к генерации исключения ConfigException.

Свойство StreamsConfig.APPLICATION_ID_CONFIG идентифицирует приложение Kafka Streams, его значение должно быть уникальным в пределах всего кластера. Оно также служит значением по умолчанию для префикса идентификатора клиента и идентификатора группы, если они не заданы. Префикс идентификатора клиента представляет собой задаваемое пользователем значение, которое однозначно идентифицирует подключающиеся к Kafka клиенты. Идентификатор группы применяется для управления членством в группе потребителей, читающих из одного топика, обеспечивая возможность чтения потребителями топиков, на которые они подписаны.

Свойство StreamsConfig.BOOTSTRAP_SERVERS_CONFIG может представлять собой одну или несколько пар имя_хоста:порт, разделенных запятыми. Значение этого параметра указывает приложению Kafka Streams на расположение кластера Kafka. Мы обсудим еще несколько элементов настроек по мере их появления в дальнейших примерах в книге.

  • Комментарий жазу үшін кіру немесе тіркелу