集成测试场景下如何将Kafka所用的RocksDB替换为内存数据库

你提到的RocksDB在Apple Silicon芯片上的适配问题，对应Kafka生态中Kafka Streams的默认状态存储实现，可通过以下配置切换为内存存储，无需再通过Rosetta运行x86架构JDK：

1. 单流任务指定内存存储（灵活适配单个业务场景） #

在编写Kafka Streams DSL代码创建状态存储时，显式指定内存存储实现即可，示例代码：

// 为单个状态流指定内存键值存储
.groupByKey()
.aggregate(
  () -> 0L,
  (key, value, aggregate) -> aggregate + value,
  Materialized.as(Stores.inMemoryKeyValueStore("count-store"))
);

2. 全局默认配置（所有流任务默认使用内存存储） #

修改Kafka Streams的启动配置参数，直接覆盖默认存储类型：

# 核心配置：将默认状态存储类型设为内存存储
default.state.store.type=in_memory

# 可选配置：限制内存存储的缓存上限，避免堆内存占用过高触发OOM
state.store.cache.max.bytes.buffering=20971520
# 上述示例值为20MB，可根据业务状态数据量自行调整

重要提醒：内存键值存储不支持持久化，应用重启、实例漂移后所有存储的状态数据会完全丢失，仅适合状态可通过上游Kafka Topic回溯重建、无持久化要求的业务场景。如果业务必须保留状态持久化能力，建议等待RocksDB发布Apple Silicon原生支持版本，或自定义实现持久化状态存储。

内容的提问来源于stack exchange，提问作者Andras Hatvani