如何将状态dir添加到嵌入式的kafka流中

Question

我正在使用嵌入的kafka for junit，我想为嵌入式kafka设置状态dir。

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

Answer 1

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

如果设置StreamsConfig是"不工作"，则必须犯错。

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

Answer 2

如果要更改经纪人正在编写数据的地方，则需要通过Properties传递相应的配置：

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

我想您想设置log.dirs？参见可用经纪人配置：https：//kafka.apache.org/documentation/#brokerconfigs