在用java在kafka中创建了连接器和sourcetask对象之后,我想不出用sourcetask对象的poll()方法返回的sourcerecords可以做什么。
如何在作为sourcerecocd参数的主题中推送记录?
我的意思是我们在 poll()
方法如下:
records.add(new SourceRecord(sourcePartition, sourceOffset, config.topicName, Schema.STRING_SCHEMA, message));
那么现在如何在主题中生成一条消息 config.topicName
在上面?
提前谢谢。
1条答案
按热度按时间sgtfey8w1#
字段
topic
从SourceRecord
示例指向将发布消息的主题。在您的情况下,它应该将消息发布到config.topicName
.