Kafka 连接自定义 Kafka Producer
Kafka Connect with custom Kafka Producer
我正在尝试构建 KafkaConnect 源连接器，想知道是否可以在此过程中 inject/use 自定义 Kafka Producer。根据文档，我得不到太多。任何想法都会有所帮助！
SourceTask 的poll方法是生产者。 Return a List<SourceRecord>，它们通过 Converter 定义序列化到配置的主题中。
如果您真的想要 Producer 对象的实际实例，那么您不应该使用 Connect API
我正在尝试构建 KafkaConnect 源连接器，想知道是否可以在此过程中 inject/use 自定义 Kafka Producer。根据文档，我得不到太多。任何想法都会有所帮助！
SourceTask 的poll方法是生产者。 Return a List<SourceRecord>，它们通过 Converter 定义序列化到配置的主题中。
如果您真的想要 Producer 对象的实际实例，那么您不应该使用 Connect API