Как добавить State Dir во встроенные потоки Kafka?

Question

Я использую встроенный Kafka для junit и хочу установить каталог состояния для встроенного Kafka.

Я попытался установить конфигурацию потоков, но она не работает.

Answer 1

Если вы хотите изменить, где брокер записывает свои данные, вам необходимо передать соответствующие конфиги через Properties:

public EmbeddedKafkaCluster(final int numBrokers,
                            final Properties brokerConfig);

Я думаю, вы хотите установить log.dirs?Срдоступная конфигурация брокера: https://kafka.apache.org/documentation/#brokerconfigs

Answer 2

Клиент не знает, что он разговаривает со встроенным Vs. настоящий брокер - они одинаковые. State.dir является концепцией только на стороне клиента.

Если настройка StreamsConfig «не работает», значит, вы допустили ошибку.

Отредактируйте свой вопрос, чтобы показать ваш код и конфигурацию.