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

Question

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

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

标签： apache-kafkaapache-kafka-streamsspring-kafka

Answer 1

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

如果设置StreamsConfig是“不工作”，你一定犯了一个错误。

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