卡夫卡高级制作人选出领导者的时间和频率是多少？是在发送每条消息之前还是在创建连接时只执行一次？
我想跟踪库存状态.我们目前正在堆栈中使用redis.目前我们使用Postgres做到这一点.每当库存进入时,我们都会增加计数,每当库存不足时,我们会减少计数.为了提高效率,我想尝试redis HIncrBy.这个操作是原子的吗？我应该注意哪些陷阱？
如果节点崩溃，并且此时邮件在邮箱中排队，那么这些邮件将如何重新处理？如果无法对其进行重新处理，那么我们如何说akka编程模型是容错的。这是最基本的用例，我们现在必须为此使用持久队列。