用Java在Kafka中创建Connector和SourceTask对象后，我无法弄清楚使用SourceTask对象的poll（）方法返回的SourceRecords可以做什么。
如何在主题（作为SourceRecocd的参数）中推送记录？
我的意思是我们在poll()方法中创建了SourceRecords，如下所示：
records.add(new SourceRecord(sourcePartition, sourceOffset, config.topicName, Schema.STRING_SCHEMA, message));
那么，现在如何在上面的
config.topicName主题中产生一条消息？提前致谢。
最佳答案
topic实例中的字段SourceRecord指向将在其中发布消息的主题。在您的情况下，它应该将消息发布到config.topicName。
关于java - 我在Kafka中与SourceRecords有什么关系，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/55032863/