kafka 做分布式任务状态维护

因为没有db等数据持久化工具，只有kafka，所以想用kafka做一个分布式Task状态维护的common类，有状态更新往kafka发，然后分布式任务订阅topic，在内存里维护任务状态，主要按照org.apache.kafka.connect.storage.KafkaOffsetBackingStore 源码的思想，不知道这个做可行么？有什么建议？