在用java在kafka中创建了连接器和sourcetask对象之后，我想不出用sourcetask对象的poll（）方法返回的sourcerecords可以做什么。
如何在作为sourcerecocd参数的主题中推送记录？
我的意思是我们在 poll() 方法如下：

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

那么现在如何在主题中生成一条消息 config.topicName 在上面？
提前谢谢。