apache-kafka - Kafka Connect 与自定义 Kafka Producer

Question

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

标签： apache-kafkaapache-kafka-connectkafka-producer-api

Answer 1

pollSourceTask的方法是生产者。返回 a List<SourceRecord>，它们会通过Converter定义序列化到配置的主题中。

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