小编Dan*_*ams的帖子

我正在尝试用 Java 创建一个消费者客户端。我意识到 poll() 函数已贬值。听卡夫卡的话题有哪些选择？

我的代码：

KafkaConsumer< String, UserSegmentPayload > kc = new KafkaConsumer<>(props2);
kc.subscribe(Collections.singletonList(topicName));
while (true) {
    ConsumerRecords<String, UserSegmentPayload> records = kc.poll(100);
    for (ConsumerRecord<String, UserSegmentPayload> record : records) {
        System.out.printf("offset = %d, key = %s, value = %s\n",
        record.offset(), record.key(), record.value());
    }
}

我正在尝试创建一个 API，它应该允许在 areospike 数据库中动态创建一个集合。

有没有办法实现这一目标？