如何将状态目录添加到嵌入式 Kafka 流？

【问题标题】：How add state dir to embedded Kafka streams?如何将状态目录添加到嵌入式 Kafka 流？
【发布时间】：2019-06-30 15:31:18
【问题描述】：

我正在为 junit 使用嵌入式 Kafka，我想为嵌入式 Kafka 设置状态目录。

我尝试设置流配置，但它不起作用。

【问题讨论】：

【解决方案1】：

客户端不知道它正在与嵌入式 Vs 对话。一个真正的经纪人 - 他们是一样的。 state.dir 只是一个客户端概念。

如果将StreamsConfig 设置为“不起作用”，则您一定犯了一个错误。

编辑您的问题以显示您的代码和配置。

【讨论】：

【解决方案2】：

如果您想更改代理写入数据的位置，您需要通过Properties 传入相应的配置：

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

我猜你想设置log.dirs？参照。可用代理配置：https://kafka.apache.org/documentation/#brokerconfigs

【讨论】：