apache-kafka - Kafka Producer 不发送消息时如何将消息保存在本地存储中？

Question

我有 120 个使用 Kakfa Producer 的数据生产者，他们每秒发送消息，有些有敏感数据（我的意思是，我们必须发送是或是），这些生产者有时可能会关闭或失去互联网连接，所以我需要容错生产者。我知道有发送它的方式，同步和异步，他们坚持尝试发送数据并将其保存在内存中，但如果我想将它保存在磁盘而不是缓冲内存中，我们怎么能这样做。如果没有发送消息，我们怎么能将消息持久保存在磁盘中？我们如何控制 Kafka 生产者何时抛出异常？

标签： apache-kafkaiotkafka-producer-api

Answer 1

在这种情况下，您对 Kafka 的用例是错误的。我建议将数据保存在 NOSQL 数据库中，而不是发送到 Kafka。