java - 我与 Kafka 中的 SourceRecords 有什么关系

Question

使用 Java 在 Kafka 中创建 Connector 和 SourceTask 对象后，我无法弄清楚可以使用 SourceTask 对象的 poll() 方法返回的 SourceRecords 做什么。

如何推送作为 SourceRecocd 参数的主题中的记录？

我的意思是我们在 poll() 方法中创建了 SourceRecords，如下所示:

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

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

提前致谢。

Answer 1

SourceRecord 实例中的

Field topic 指向将发布消息的主题。在您的情况下，它应该将消息发布到 config.topicName。