怎么在Java中利用卡夫卡对客户端进行访问

　　介绍

这篇文章给大家介绍怎么在Java中利用卡夫卡对客户端进行访问,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。

<强> 1。maven依赖包

& lt; dependency> 　　& lt; groupId> org.apache.kafka 　　& lt; artifactId> kafka-clients 　　& lt; version> 0.9.0.1 　　& lt;/dependency>

<强> 2。生产者代码 

包com.lnho.example.kafka;
　　
　　进口org.apache.kafka.clients.producer.KafkaProducer;
　　进口org.apache.kafka.clients.producer.Producer;
　　进口org.apache.kafka.clients.producer.ProducerRecord;
　　
　　进口java.util.Properties;
　　
　　公开课KafkaProducerExample {
　　公共静态void main (String [] args) {
　　属性道具=new属性();
　　props.put (“bootstrap.servers",“主人:9092“);
　　props.put (“acks",“all");
　　props.put (“retries" 0);
　　props.put (“batch.size", 16384);
　　props.put (“linger.ms", 1);
　　props.put (“buffer.memory", 33554432);
　　props.put (“key.serializer",“org.apache.kafka.common.serialization.StringSerializer");
　　props.put (“value.serializer",“org.apache.kafka.common.serialization.StringSerializer");
　　
　　String> Producer<字符串;制片人=new KafkaProducer<祝辞(道具);
　　for (int i=0;我& lt;100;我+ +)
　　生产商。发送(新ProducerRecord<祝辞(“topic1", Integer.toString(我),Integer.toString(我)));
　　
　　producer.close ();
　　｝
　　}

<强> 3。消费者代码 

包com.lnho.example.kafka;
　　
　　进口org.apache.kafka.clients.consumer.ConsumerRecord;
　　进口org.apache.kafka.clients.consumer.ConsumerRecords;
　　进口org.apache.kafka.clients.consumer.KafkaConsumer;
　　
　　进口java.util.Arrays;
　　进口java.util.Properties;
　　
　　公开课KafkaConsumerExample {
　　公共静态void main (String [] args) {
　　属性道具=new属性();
　　props.put (“bootstrap.servers",“主人:9092“);
　　props.put (“group.id",“test");
　　props.put (“enable.auto.commit",“true");
　　props.put (“auto.commit.interval.ms",“1000“);
　　props.put (“session.timeout.ms",“30000“);
　　props.put (“key.deserializer",“org.apache.kafka.common.serialization.StringDeserializer");
　　props.put (“value.deserializer",“org.apache.kafka.common.serialization.StringDeserializer");
　　String> KafkaConsumer<字符串;消费者=new KafkaConsumer<祝辞(道具);
　　consumer.subscribe (arrays . aslist (“topic1"));
　　而(真){
　　String> ConsumerRecords<字符串;记录=consumer.poll (100);
　　(ConsumerRecord<字符串,String>记录:记录)
　　System.out.printf(“抵消=% d键=% s value=https://www.yisu.com/zixun/%s/n”, record.offset (), record.key (), record.value ());
　　｝
　　｝
　　}

<>强4。执行程序

自由底下需要有:kafka-clients-0.9.0.1。jar log4j-1.2.17。jar slf4j-api-1.7.6。jar slf4j-log4j12-1.7.6。jar

生产者:

java类路径卡夫卡——- 1.0 -快照示例。jar: lib/* com.lnho.example.kafka。KafkaProducerExample

消费者:

java类路径卡夫卡——- 1.0 -快照示例。jar: lib/* com.lnho.example.kafka。KafkaConsumerExample

关于怎么在Java中利用卡夫卡对客户端进行访问就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看的到。

怎么在Java中利用卡夫卡对客户端进行访问