如何作为Kafka配置的初学者快速入门（如何配置Kafka）

消费者示例（Java）：

导入org.apache.kafka.clients.consumer.consumerrecord;导入org.apache.kafka.clients.consumer.consumerrecords;导入org.apache.kafka.clients.consumer.kafkaconsumer;导入java.duration;导入java.util.util.util.util.util.util.util.util.utilクラスkafkaconsumerexample {public static void main tring string [] args） props.put（bootstrap.servers，localhost：9092）; props.put（group.ID，测试组）; props.put（键。 props.put（value.deserializer，org.apache.kafka.common.serialization.stringDeserializer）; kafkaconsumer字符串，字符串消费者=新的kafkaconsumer（props）; consumer.subscribe（arrays.aslist（test_topic））; while（true）{commuterRecords string，字符串记录= computer.poll（listation.ofmillis（100））; for（反记录字符串，字符串记录：记录）{system.out.printf（offset =％d，key =％s，value =％s％n，record.offset（），record.key（），record.value（））;

这几篇文章你可能也喜欢：

• 配置Kafka生产商时要注意什么？
• 如何优化Kafka消费者绩效（Kafka消费者如何消耗数据）
• 如何将文件移至Linux上的指定目录？ （Linux将文件移至另一个目录命令）
• 如何使用LNMP体系结构（LNMP调整）优化数据库查询
• 如果我的Linux Crond任务延迟了怎么办？

本文由主机参考刊发，转载请注明：如何作为Kafka配置的初学者快速入门（如何配置Kafka） https://zhujicankao.com/145590.html