开发者社区> 问答> 正文

FlinkKafkaProducer提供的构造函数有哪些呢?

FlinkKafkaProducer提供的构造函数有哪些呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-07 21:55:17 349 0
1 条回答
写回答
取消 提交回答
  • 与Kafka源连接器类似,可以为Kafka客户端传递一个Properties对象来提供定制选项。在使用Properties时,必须将brokers列表作为“bootstrap.servers”属性。查看Kafka文档以获得完整的参数列表。

    可以指定一个FlinkKafkaPartitioner来控制记录如何映射到Kafka分区。我们将在本节后面更深入地讨论这个特性。

    还可以指定KeyedSerializationSchema,而不是使用SerializationSchema将记录转换为字节数组,KeyedSerializationSchema将记录序列化为两个字节数组—一个用于键,另一个用于Kafka消息的值。

    2021-12-07 22:51:06
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载