检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
地址,<subscribe-type>指Kafka订阅类型(一般为subscribe,代表订阅指定的topic),<topic>指读取Kafka上的topic名称,<protocol>指安全访问协议,<service>指kerberos服务名称,<domain>指kerberos域名
约束限制: 不涉及 取值范围: 不涉及 默认取值: 不涉及 azName String 参数解释: 可用区域名称。 约束限制: 不涉及 取值范围: 不涉及 默认取值: 不涉及 azCode String 参数解释: 可用区域英文名称。
Spark之所以默认没有使用Kryo作为序列化类库,是因为Kryo要求要注册所有需要进行序列化的自定义类型,因此对于开发者来说,这种方式比较麻烦。 Spark Streaming性能优化建议 设置合理的批处理时间(batchDuration)。 设置合理的数据接收并行度。
约束限制: 不涉及 取值范围: 不涉及 默认取值: 不涉及 azName String 参数解释: 可用区域名称。 约束限制: 不涉及 取值范围: 不涉及 默认取值: 不涉及 azCode String 参数解释: 可用区域英文名称。
Replicated系列引擎借助ZooKeeper实现数据的同步,创建Replicated复制表时通过注册到ZooKeeper上的信息实现同一个分片的所有副本数据进行同步。
Replicated系列引擎借助ZooKeeper实现数据的同步,创建Replicated复制表时通过注册到ZooKeeper上的信息实现同一个分片的所有副本数据进行同步。