配置类问题

百度消息服务支持的哪一版的Kafka?

Kafka是一个演化中的系统,目前百度消息服务服务支持0.10版本的Kafka。

什么是主题(TOPIC)?必须要创建吗?

您需要先创建主题然后才能读写。主题是全局唯一的。

什么是分区(PARTITION)?

分区是Kafka用来水平扩展主题吞吐的设计,发布的消息将被写入不同分区,被若干消费者同时读取。本质上,主题的吞吐与分区个数成正比。

吞吐包含了生产者与消费者,所以分区个数计算公式是:max(t/p,t/c),其中t、p、c分别代表期望的总通量、生产者在一个分区通量、消费者在一个分区通量。

由于消息是以队列的形式缓存在Kafka中,分区个数并不需要按照峰值来设置,而只要按照平均值来设置即可,当然缺点是延时会提高。

什么是客户端?

您可以通过Kafka客户端连接消息中心,并且把代码部署在多个百度智能云服务BCC或应用引擎BAE实例中生产或者消费消息。