检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
static void main(String[] args) throws IOException { //创建当前消费组的consumer final KafkaConsumer<String, String> consumer1 = getConsumer();
获取方法如下：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。 security_group_id 是 String 指定实例所属的安全组。 获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。 subnet_id 是 String 子网信息。
PLAINTEXT：表示实例未开启SASL_SSL。 direction 否 String 同步方向；pull为把对端Kafka实例数据复制到当前Kafka实例中，push为把当前Kafka实例数据复制到对端Kafka实例中，two-way为对两端Kafka实例数据进行双向复制。（仅源端类型为Kafka时需要填写）
默认Topic的副本数为3 实例网络总流量 = 单个代理流量规格 * 代理数量 实例整体流量 = 业务流量 + 代理节点间数据复制流量 参考上述测算模型说明，假如当前规格为kafka.2u4g.cluster，单个代理流量规格为100MB/s，代理数量为3，实例网络总流量、最大读流量和最大写流量分别为多少？
是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 action 否 String 删除类型。当前只支持delete。 当删除用户时，为必选参数。 users 否 Array of strings 用户列表。 当删除用户时，为必选参数。
0及之后版本：true 如果无幂等需求，建议设置为false。 在生产者客户端中开启幂等，然后生产消息，此时您会在消费者客户端或Kafka控制台的“消息查询”中观察到消息offset不连续的现象。这是因为开启了幂等后，在生产消息时会产生一些元数据控制消息，这些控制消息也会生产到该Topic中，
default_value String 默认值。 config_type String 配置类型：static/dynamic。 value String 配置当前值。 value_type String 值类型。 请求示例 GET https://{endpoint}/v2/{project_id}
s。 security_group_id 否 String 安全组ID。 获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。 retention_policy 否 String 容量阈值策略。 支持两种策略模式： produce_reject: 生产受限
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
