Kafka系统

相关主题

Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理，也是为了通过集群来提供实时的消息。

目前MapGIS在前端的一些应用产品中需要依赖Kafka系统。

• 创建集群
• 集群运维

创建集群

提示：

1. Kafka系统依赖zookeeper组件。因此，用户在安装部署Kafka系统前，必须保证完成了zookeeper组件的部署。

1. 基本创建过程可参考"创建Elasticsearch集群"章节，此章节不在赘述。操作过程中，需选择"其它"->"ZooKeeper"类型，如下图所示：

2. 全局配置中按照相关示例提示，正确填写"参数值"列有关Zookeeper的路径。

提示：

1. 创建ZooKeeper集群时，建议节点个数为1/3/5/7等单数，避免为双数。

集群运维

Kafka系统创建后，可执行启动/停止、查看集群信息、启用密码、卸载集群、注销集群等操作，其基本操作步骤与"Elasticsearch"类似。

提示：

Kafka组件启用密码时，用户需为安装用户MapGisDataStore设置密码。启用密码后，Kafka的应用均需密码验证，可使用此用户及密码信息。