这家伙太懒,什么都没留下
好的,是时候更新一版新的了。
step6 中出现的 "bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic my-replicated-topic" 可能需要修改为 "bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning" , 对照官方文档应该是这样的
nice!
不对,兄弟,此话想表达的是流式系统的耐用性,所谓的健壮性(故障转移容错的能力),而不是持久化的意思。
流式系统
如果还有其他的地方,多多指正。