Kafka Connect с заказным производителем Kafka

Question

Я пытаюсь создать исходный соединитель KafkaConnect, и мне было интересно, можно ли в процессе внедрить / использовать пользовательский Kafka Producer. Согласно документации, я не мог получить много. Любые идеи помогут!

Answer 1

Метод poll SourceTask является производителем. Вернуть List<SourceRecord>, и они будут сериализованы в сконфигурированную topi c через определения Converter.

Если вы действительно хотите фактический экземпляр объекта Producer, вам не следует использовать Connect API