代理(Broker) 即Kafka集群架构设计中的单个Kafka进程,一个Kafka进程对应一台服务器,因此手册中描述的代理,还包括对应的存储、带宽等服务器资源。
示例如下: [root@ecs-kafka bin]# .
示例如下: [root@ecs-kafka bin]# .
示例如下: [root@ecs-kafka bin]# .
客户端网络环境说明 客户端可以通过以下方式访问Kafka实例: 如果客户端是云上ECS,与Kafka实例处于同region同VPC,则可以直接访问Kafka实例提供的内网连接地址。
ecs_flavor_id String 该产品使用的ECS规格。 arch_types Array of strings 支持的CPU架构类型。 charging_mode Array of strings 支持的计费模式类型。
[root@ecs-kafka bin]# .
示例如下: [root@ecs-kafka bin]# .
Kafka服务和ZK是部署在相同的虚拟机中,还是分开部署? Kafka包周期实例支持删除吗? Kafka支持哪些加密套件? 购买实例时选择的单AZ,怎样可以扩展为多AZ? Kafka是否支持跨AZ容灾?已经购买的实例在哪里查看是否为跨AZ? Kafka支持磁盘加密吗?
示例如下: [root@ecs-kafka bin]# .
ecs_flavor_id String 该产品使用的ECS规格。 arch_types Array of strings 支持的CPU架构类型。 charging_mode Array of strings 支持的计费模式类型。
示例如下: [root@ecs-kafka bin]# .
broker_memory_usage 内存使用率 节点 告警阈值:原始值>90% 连续触发次数:3 告警级别:紧急 该指标为Kafka节点虚拟机层面采集的内存使用率。 出现该告警时,需要修改实例基准带宽/代理个数,即扩节点。具体操作,请参考变更实例规格。
[root@ecs-kafka bin]#.
[root@ecs-test confluent-kafka-go]# go version go version go1.16.5 linux/amd64 如果未安装Go,参考如下步骤安装。 #下载Go安装包。
重启Kafka实例只会重启实例进程,不会重启实例所在虚拟机。 相关文档 如果您希望通过API重启Kafka实例,请参考批量重启或删除实例。 父主题: 管理实例
ecs_flavor_id String 参数解释: 底层资源类型。 取值范围: 不涉及。 billing_code String 参数解释: 账单计费类型。 取值范围: 不涉及。 arch_types Array of strings 参数解释: CPU架构。
示例如下: [root@ecs-kafka bin]# .
[root@ecs-test ~]# python3 producer.py start producer end producer [root@ecs-test ~]# 消费消息 在客户端创建一个文件,用于存放消费消息的代码示例。
ssl.truststore.location=E:\\temp\\client.pem #ssl.truststore.password为服务器证书密码,使用PEM格式证书访问Kafka实例,无需配置ssl.truststore.password参数。