检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
exactly-once none sink.parallelism 否 无 Integer 定义Kafka sink算子的并行度。 默认情况下，由框架确定并行度，与上游链接算子的并行度保持一致。 ssl_auth_name 否 无 String DLI侧创建的Kafka_SSL类型
初始化consumer/producer都是在taskmanager里执行的，所以需要获取到taskmanager对应container下truststore文件的路径，在初始化前将其引入properties中才能生效。 kafka source可以在open里引入。 图1 获取kafka
String startingOffsets = params.get("startOffset"); // 消费组标识，同一个消费组下的不同客户端可以同时消费同一个通道 String groupId = params.get("groupId");
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
