чо за параметр?
Обычный консумер отваливается после какой-то неудачной попытки подключиться. А вот админ-клиент по-моему до талого пытается что-то сделать
как-то его можно переубедить? Чето страдаю с тем чтобы найти нужную конфигурацию под это
https://kafka.apache.org/documentation.html#adminclientconfigs_retries
а что вообще можно почитать про нечто вида ${cluster}? А то судя по всему, мне этот параметр подставить и нужно, но видимо надо откуда идентификатор кластера вытащить? (отсюда статья) Я попробовал втупую сделать .option("spark.kafka.clusters.${cluster}.kafka.retries", 1) но эффекта нет
Обсуждают сегодня