如何作为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（））;

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

• 如何远程管理Linux Monit
• 如何解决Zookeeper启动故障问题（如何解决动物园管理器启动失败问题）
• 如何修改Linux Monit配置文件
• 什么是基本的Ubuntu命令（基本Ubuntu命令的摘要）
• 分布式系统的Zookeeper应用程序案例（Zookeeper是用于管理许多主机的分布式协调服务）

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