我在 Kafka 中与 SourceRecords 有什么关系

Question

在使用 Java 在 Kafka 中创建连接器和 SourceTask 对象后，我不知道可以用 SourceTask 对象的 poll() 方法返回的 SourceRecords 做什么。

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

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

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

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

提前致谢。

Answer 1

SourceRecord 实例中的 topic 字段指向将发布消息的主题。在您的情况下，它应该将消息发布到 config.topicName.

What I have to do with SourceRecords in Kafka