标签 "Kafka" 下的文章

公司电脑存储是 128G 的,之前为了腾出空间,删除了整个 Docker 环境,它占据了我整整 60G 的磁盘空间。

后面还花了时间,把自己的开发环境,逐步迁移到公司提供的测试环境上,很多组件不需要自己搞了,很舒服。

不过,测试环境的资源经常挂掉(可能用的人多,也可能是使用的姿势不对),又得自己动手了……

简单记录一下安装的过程:

brew install java kafka

经历了漫长的等待,你会看到安装成功的提示。使用下面命令启动 Zookeeper 和 Kafka:

zookeeper-server-start /opt/homebrew/etc/kafka/zookeeper.properties
kafka-server-start /opt/homebrew/etc/kafka/server.properties

Enjoy!

使用消息队列,我们肯定希望不丢消息,也就是消息队列组件,需要保证消息的可靠交付。消息交付的可靠性保障,有以下三种承诺:

  • 最多一次(at most once):消息可能会丢失,但绝不会被重复发送。
  • 至少一次(at least once):消息不会丢失,但有可能被重复发送。
  • 精确一次(exactly once):消息不会丢失,也不会被重复发送。

默认是一般是 至少一次,也就是 Broker 收到并成功提交消息,并且 Producer 成功应答才会认为消息已经发送。

某些情况下,比如网络波动等,导致应答没有成功送达,会导致 Producer 重试,从而导致消息的重复发送。

阅读全文