Kafka

作者: 泓礼 | 来源:发表于2019-01-11 21:56 被阅读0次

1. KafkaProducer是系统的大入口

可以用这个producer向任意的topic发送消息,而发送到哪个topic是由构造的Message来确定

当用惯了一个log/stream应该由一个专门的writer来进行写入的系统(Apache BookKeeper,Pulsar)后,会发现这种模式有些怪异,producer有些名不达意,不是针对一个topic的producer,竟然是超级大入口,这样的话,如何进行client赋权,隔离等,应该会更麻烦。

此外,当topic不存在时,直接向此topic写,会触发topic的自动创建,确实比较好用,但治理不够好,层次有些不清晰。

2.Kafka的简洁

不得不说,kafka的配置参数极少,上手即为简单,只暴露给用户log存储位置,zk地址等简单的配置项,因此bk的配置项可以考虑分为普通的和高级的,考虑到更多的人群。

3.规范地创建topic(在java工程中)

需要引用kafka.admin依赖,首先创建zk client,然后创建topic。

相关文章

网友评论

      本文标题:Kafka

      本文链接:https://www.haomeiwen.com/subject/dpefdqtx.html