Kafka 连接自定义 Kafka Producer

Question

我正在尝试构建一个 KafkaConnect 源连接器，想知道是否可以在此过程中注入/使用自定义 Kafka Producer 。根据文档，我无法得到太多。任何想法都会有所帮助！

Answer 1

SourceTask 的poll方法是生产者。返回一个List<SourceRecord>，它们通过Converter定义被序列化到配置的主题中。

如果你真的想要一个生产者对象的实际实例，那么你不应该使用Connect API。