Что я должен делать с SourceRecords в Кафке

Question

После создания объектов Connector и SourceTask в Kafka с Java я не могу понять, что можно сделать с помощью метода SourceRecords, возвращенного form poll () объекта SourceTask.

Как вставить запись втема, которая является параметром SourceRecocd?

Я имею в виду, что у нас есть создание SourceRecords в методе poll() следующим образом:

    records.add(new SourceRecord(sourcePartition, sourceOffset, config.topicName, Schema.STRING_SCHEMA, message));

Итак, как создать сообщение в теме?что на config.topicName выше?

Заранее спасибо.

Answer 1

Поле topic из экземпляра SourceRecord указывает на тему, где будет опубликовано сообщение. В вашем случае следует опубликовать сообщение на config.topicName.